import { Observable } from 'rxjs/Observable'; import { Observer } from 'rxjs/Observer'; export declare abstract class ClientProxy { protected abstract sendSingleMessage(msg: any, callback: (err, result, disposed?: boolean) => void): any; send(pattern: any, data: any): Observable; protected createObserver(observer: Observer): (err, result, disposed?: boolean) => void; }