import { Cancellable, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber, Payload, Requestable } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { SchedulerLike, Subscriber, TeardownLogic } from "rxjs";
import ObserverToBufferingRSocketSubscriber from "./ObserverToBufferingRSocketSubscriber";
import RSocketPublisherToPrefetchingObservable from "./RSocketPublisherToPrefetchingObservable";
interface RSocketPublisher2PrefetchingObservableToObserver2BufferingRSocketSubscriber<IN, OUT> extends ObserverToBufferingRSocketSubscriber<OUT>, RSocketPublisherToPrefetchingObservable<IN, OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber & Requestable & Cancellable> {
    readonly subscriber: OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable;
    forEach(x: any): any;
}
declare class RSocketPublisher2PrefetchingObservableToObserver2BufferingRSocketSubscriber<IN, OUT> extends RSocketPublisherToPrefetchingObservable<IN, OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber & Requestable & Cancellable> {
    readonly firstPayload: Payload;
    readonly isCompleted: boolean;
    constructor(firstPayload: Payload, isCompleted: boolean, subscriber: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber & Requestable & Cancellable, requested: number, prefetch: number, outputCodec: Codec<IN>, inputCodec: Codec<OUT>, scheduler?: SchedulerLike);
    protected _subscribe(observer: Subscriber<any>): TeardownLogic;
}
export default RSocketPublisher2PrefetchingObservableToObserver2BufferingRSocketSubscriber;