/// <reference types="rx-core" />
/// <reference types="rx-core-binding" />
/// <reference types="rx-lite" />
/// <reference types="rx-lite-aggregates" />
/// <reference types="rx-lite-backpressure" />
/// <reference types="rx-lite-coincidence" />
/// <reference types="rx-lite-experimental" />
/// <reference types="rx-lite-joinpatterns" />
/// <reference types="rx-lite-time" />
/// <reference types="node" />
import rx = require('rx');
import stream = require('stream');
import apihandler = require('apihandler');
export interface IRPC {
    getUser(): any | undefined;
    call<T>(name: string, params?: any): rx.Observable<T>;
    accept(name: string, service: any): this;
    open(): void;
    on(event: string, listener: Function): this;
    emit(event: string | symbol, ...args: any[]): boolean;
}
export interface IAuth<TUser> {
    handshake(): Buffer;
    accept(buffer: Buffer): rx.Observable<apihandler.IUser<TUser>>;
}
export interface Options<TUser> {
    name: string;
    auth: IAuth<TUser>;
    duplex: stream.Duplex;
    loader?: apihandler.ILoader;
    timeout?: number;
}
export declare class Peer<TUser> implements IRPC {
    private options;
    private user?;
    private idgen;
    private context;
    private pending;
    private streamBuffer;
    private recvBuffer;
    private timer;
    private state;
    private emitter;
    constructor(options: Options<TUser>);
    getUser(): any | undefined;
    on(event: string, listener: Function): this;
    emit(event: string | symbol, ...args: any[]): boolean;
    open(): void;
    close(): void;
    call<T>(name: string, params?: any): rx.Observable<T>;
    accept(name: string, service: any): this;
    private init();
    private handleTimeout();
    private handlshake();
    private onResponse(data);
    private handleRequest(code, data);
    private handleResponse(code, data);
    private handleAuth(code, data);
    private handleAuthResp(code, data);
    private onData(code, data);
}