/// <reference types="node" />
import { Cancellable, OnExtensionSubscriber, OnNextSubscriber, OnTerminalSubscriber } from "rsocket-core";
import { Codec } from "rsocket-messaging";
import { Observer, Subscription } from "rxjs";
export default class ObserverToRSocketSubscriber<T> extends Subscription implements Observer<T>, Cancellable, OnExtensionSubscriber {
    private readonly subscriber;
    private readonly codec;
    constructor(subscriber: T extends void | null | undefined ? OnTerminalSubscriber : OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber, codec: T extends void | null | undefined ? undefined : Codec<T>);
    onExtension(extendedType: number, content: Buffer, canBeIgnored: boolean): void;
    cancel(): void;
    next(value?: T): void;
    error(err?: any): void;
    complete(): void;
}