import { Cancellable, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber, Requestable } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observable, Observer, SchedulerLike, Subscriber, TeardownLogic, Unsubscribable } from "rxjs";
import ObserverToBufferingRSocketSubscriber from "./ObserverToBufferingRSocketSubscriber";
import RSocketPublisherToPrefetchingObservable from "./RSocketPublisherToPrefetchingObservable";
interface Observer2BufferingSubscriberToPublisher2PrefetchingObservable<In, Out> extends ObserverToBufferingRSocketSubscriber<In>, RSocketPublisherToPrefetchingObservable<Out, OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable> {
    subscriber: OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable;
    forEach(next: any): any;
}
declare class Observer2BufferingSubscriberToPublisher2PrefetchingObservable<In, Out> extends RSocketPublisherToPrefetchingObservable<Out, OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable> implements Observer<In>, Unsubscribable, OnNextSubscriber, OnTerminalSubscriber, OnExtensionSubscriber, Requestable, Cancellable {
    private readonly restObservable;
    constructor(exchangeFunction: (s: OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable, n: number) => OnNextSubscriber & OnTerminalSubscriber & OnExtensionSubscriber & Requestable & Cancellable, prefetch: number, restObservable: Observable<In>, inputCodec: Codec<In>, outputCodec: Codec<Out>, scheduler?: SchedulerLike);
    _subscribe(s: Subscriber<Out>): TeardownLogic;
    unsubscribe(): void;
}
export default Observer2BufferingSubscriberToPublisher2PrefetchingObservable;