import { Subject } from 'rxjs';
import { DeferredData, Rpc } from './rpc';
export declare class RpcSubjectServer<TData, TResult> {
    protected rpc: Rpc;
    subject: Subject<DeferredData<TData, TResult>>;
    constructor(rpc: Rpc, command: string);
    protected processNextForSubject(command: string, data: TData): Promise<TResult>;
    protected handler(data: TData): Promise<TResult>;
}