import { OperatorFunction } from 'rxjs';
import { SbQueueSubscriptionMetadataOptions, SbSubscriptionMetadataOptions, SbInterceptor } from '../../interfaces';
import { SbContext } from '../../sb-context';
export declare type PropOrMethodDecorator<TVar, TTrue> = TVar extends TTrue ? MethodDecorator : <T extends Record<K, OperatorFunction<SbContext, any>>, K extends string>(target: T, key: K) => void;
/**
 * Subscribes to incoming events from a queue
 */
export declare function Queue<T = false>(metadata: SbQueueSubscriptionMetadataOptions): PropOrMethodDecorator<T, MethodDecorator>;
/**
 * Subscribes to incoming events from a topic
 */
export declare function Subscription<T = false>(metadata: SbSubscriptionMetadataOptions): PropOrMethodDecorator<T, MethodDecorator>;
export declare function SbIntercept(...interceptors: Array<SbInterceptor>): <T extends Record<K, OperatorFunction<SbContext<"queue" | "subscription">, any>>, K extends string>(target: T, key: K) => void;
//# sourceMappingURL=subscriber.d.ts.map