Как правильно дернуть observer из другого метода?

Question

[nuclear_kote]

Грубо говоря есть метод login который посылает команду на вебсокет, после ответа в onMessage нужно чтобы Observable отработал. т.е subscribe сработал или error.

EventEmitter очень не хотелось бы юзать, а обсервера выносить я так понимаю не совсем правильно

Answer 1

[Антон Цепковский]

Вы код покажите, не совсем понятно что Вы дергать собрались и зачем.

Answer 2

[Pavel Shvedov]

Не нужно дергать обзервер, нужно эмитить значение в обзервабл, а обзервер должен быть на него подписан

Comments

[nuclear_kote]

ws = new Websocket("localhost/app");
    
    emitter = new EventEmitter();

     ws.onmessage = event => {
       if (event.data .... == 'success') {
         emitter.emit('blablalbla');
       } else {
         emitter.error('blablalbla');
      }
    };
    private timeoutError(observer) {
        setTimeout(() => {
            observer.error();
        }, 5000);
    }

    public login(login: string, password): Observable<any> {
        ws.send(login, password);
        return new Observable(observer => {
            this.emitter.subscribe(() => {
                    observer.next();
                    observer.complete();
                },
                () => observer.error()
            );
            this.timeoutError(observer)
        });
    }

типа того?