/// <reference types="node" />
import { Cancellable, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber, Requestable } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observer, Subscription } from "rxjs";
interface ObserverToBufferingRSocketSubscriber<T> extends Subscription, Array<T>, Observer<T>, Cancellable, Requestable, OnExtensionSubscriber {
}
declare class ObserverToBufferingRSocketSubscriber<T> extends Subscription implements Observer<T>, Cancellable, Requestable, OnExtensionSubscriber {
    protected requested: number;
    protected readonly subscriber: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber;
    protected readonly inputCodec: Codec<T>;
    protected wip: number;
    private e;
    private done;
    constructor(requested: number, subscriber: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber, inputCodec: Codec<T>);
    request(n: number): void;
    cancel(): void;
    onExtension(extendedType: number, content: Buffer, canBeIgnored: boolean): void;
    next(value: T): void;
    error(err: any): void;
    complete(): void;
    private drain;
}
export default ObserverToBufferingRSocketSubscriber;