AlexDaSoul

private connect(): void {
    this.websocket$ = new WebSocketSubject(this.config); // создаем

// если есть сообщения, шлем их в дальше,
// если нет, ожидаем
// реконнектимся, если получили ошибку
this.websocket$.subscribe(
    (message) => this.wsMessages$.next(message),
    (error: Event) => {
        if (!this.websocket$) {

AlexDaSoul

private reconnect(): void {
    // Создаем interval со значением из reconnectInterval
    this.reconnection$ = interval(this.reconnectInterval)
        .pipe(takeWhile((v, index) => index < this.reconnectAttempts && !this.websocket$));

// Пытаемся подключиться пока не подключимся, либо не упремся в ограничение попыток подключения
this.reconnection$.subscribe(
    () => this.connect(),
    null,
    () => {

AlexDaSoul

public on<T>(event: string): Observable<T> {
    if (event) {
        return this.wsMessages$.pipe(
            filter((message: IWsMessage<T>) => message.event === event),
            map((message: IWsMessage<T>) => message.data)
        );
    }
}

AlexDaSoul

public send(event: string, data: any = {}): void {
    if (event && this.isConnected) {
        // костыль с any потому, что на "том" конце ожидается string
        // более изящный костыль не придумался :)
        this.websocket$.next(<any>JSON.stringify({ event, data }));
    } else {
        console.error('Send error!');
    }
}

AlexDaSoul

imports: [
    WebsocketModule.config({
        url: environment.ws // или просто ссылка в виде 'ws://www.example.com'
    })
]

AlexDaSoul

constructor(private wsService: WebsocketService) {
    this.wsService.on<IMessage[]>('messages')
        .subscribe((messages: IMessage[]) => {
            console.log(messages);

            this.wsService.send('text', 'Test Text!');
        });
}

AlexDaSoul

export const WS = {
    ON: {
        MESSAGES: 'messages'
    },
    SEND: {
        TEXT: 'text'
    }
};

AlexDaSoul

this.wsService.on<IMessage[]>(WS.ON.MESSAGES)
    .subscribe((messages: IMessage[]) => {
        console.log(messages);

        this.wsService.send(WS.SEND.TEXT, 'Test Text!');
    });

AlexDaSoul

export interface IWebsocketService { // публичный интерфейс сервиса
    addEventListener<T>(topics: string[], id?: number): Observable<T>;
    runtimeIgnore(topics: string[]): void;
    runtimeRemoveIgnore(topics: string[]): void;
    sendMessage(event: string, data: any): void;
}

export interface WebSocketConfig { // конфиг при DI
    url: string;
    ignore?: string[];

AlexDaSoul

export class MessageSubject<T> extends Subject<T> {

    constructor(
        private listeners: IListeners, // объект с топиками
        private topic: string, // текущий топик
        private id: string // id сабжекта
    ) { 
        super();
    }