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