/// <reference types="node" />
import { Cancellable, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber, Payload, Requestable } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observable, SchedulerLike, Subscriber, TeardownLogic, Unsubscribable } from "rxjs";
export default class RSocketPublisherToPrefetchingObservable<T, TSignalSender extends Requestable & Cancellable & OnExtensionSubscriber> extends Observable<T> implements OnTerminalSubscriber, OnNextSubscriber, OnExtensionSubscriber, Unsubscribable {
    private readonly exchangeFunction;
    protected readonly prefetch: number;
    private readonly responseCodec?;
    protected readonly scheduler: SchedulerLike;
    private readonly limit;
    private observer;
    protected subscriber: TSignalSender;
    private received;
    constructor(exchangeFunction: (subscriber: OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber, n: number) => TSignalSender, prefetch: number, responseCodec?: Codec<T>, scheduler?: SchedulerLike);
    onNext(payload: Payload, isComplete: boolean): void;
    onError(error: Error): void;
    onComplete(): void;
    onExtension(extendedType: number, content: Buffer, canBeIgnored: boolean): void;
    unsubscribe(): void;
    protected _subscribe(observer: Subscriber<any>): TeardownLogic;
}