import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/publishReplay';
export interface IWebSocketMessageService<T> {
    messages$: Observable<T>;
}
export declare abstract class WebSocketMessageServiceBase<T> implements IWebSocketMessageService<T> {
    private _messages$;
    readonly messages$: Observable<T>;
    private readonly _baseUrl;
    constructor(baseUrl: string);
    protected connect(): void;
    protected abstract getServerUrl(): Observable<string>;
}