import { DeadLetterOptions } from '@azure/service-bus';
import { SbContext } from '@pebula/attribus';
export declare const completeMessage: () => <T extends SbContext<"queue" | "subscription">>(source: import("rxjs").Observable<T>) => import("rxjs").Observable<T>;
export declare const abandonMessage: (propertiesToModify?: {
    [key: string]: any;
}) => <T extends SbContext<"queue" | "subscription">>(source: import("rxjs").Observable<T>) => import("rxjs").Observable<T>;
export declare const deferMessage: (propertiesToModify?: {
    [key: string]: any;
}) => <T extends SbContext<"queue" | "subscription">>(source: import("rxjs").Observable<T>) => import("rxjs").Observable<T>;
export declare const deadLetter: (options?: DeadLetterOptions) => <T extends SbContext<"queue" | "subscription">>(source: import("rxjs").Observable<T>) => import("rxjs").Observable<T>;
export declare const block: () => import("rxjs").MonoTypeOperatorFunction<unknown>;
//# sourceMappingURL=rx-operators.d.ts.map