/// <reference types="node" />
import { WellKnownMimeType } from "rsocket-composite-metadata";
import { RSocket } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observable, SchedulerLike } from "rxjs";
export declare function fireAndForget<TData>(data: TData, inputCodec: Codec<TData>): (rsocket: RSocket, metadata?: Map<string | number | WellKnownMimeType, Buffer>) => Observable<void>;
export declare function requestResponse<TData, RData>(data: TData, inputCodec: Codec<TData>, outputCodec: Codec<RData>): (rsocket: RSocket, metadata?: Map<string | number | WellKnownMimeType, Buffer>) => Observable<RData>;
export declare function requestStream<TData, RData>(data: TData, inputCodec: Codec<TData>, outputCodec: Codec<RData>, prefetch?: number, scheduler?: SchedulerLike): (rsocket: RSocket, metadata?: Map<string | number | WellKnownMimeType, Buffer>) => Observable<RData>;
export declare function requestChannel<TData, RData>(datas: Observable<TData>, inputCodec: Codec<TData>, outputCodec: Codec<RData>, prefetch?: number, scheduler?: SchedulerLike): (rsocket: RSocket, metadata?: Map<string | number | WellKnownMimeType, Buffer>) => Observable<RData>;