import { Cancellable, FrameTypes, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber, Payload, Requestable } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observable, SchedulerLike } from "rxjs";
export declare function fireAndForget<IN>(handler: (data: IN) => Observable<void>, codec: Codec<IN>): ((p: Payload, s: OnTerminalSubscriber) => Cancellable) & {
    requestType: FrameTypes.REQUEST_FNF;
};
export declare function requestResponse<IN, OUT>(handler: (data: IN) => Observable<OUT>, codecs: {
    inputCodec: IN extends void | null | undefined ? undefined : Codec<IN>;
    outputCodec: OUT extends void | null | undefined ? undefined : Codec<OUT>;
}): ((p: Payload, s: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber) => Cancellable & OnExtensionSubscriber) & {
    requestType: FrameTypes.REQUEST_RESPONSE;
};
export declare function requestStream<IN, OUT>(handler: (data: IN) => Observable<OUT>, codecs: {
    inputCodec: Codec<IN>;
    outputCodec: Codec<OUT>;
}): ((p: Payload, r: number, s: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber) => Cancellable & OnExtensionSubscriber & Requestable) & {
    requestType: FrameTypes.REQUEST_STREAM;
};
export declare function requestChannel<IN, OUT>(handler: (dataStream: Observable<IN>) => Observable<OUT>, codecs: {
    inputCodec: Codec<IN>;
    outputCodec: Codec<OUT>;
}, prefetch?: number, scheduler?: SchedulerLike): ((payload: Payload, initialRequestN: number, isCompleted: boolean, s: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber & Requestable & Cancellable) => OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber & Requestable & Cancellable) & {
    requestType: FrameTypes.REQUEST_CHANNEL;
};