У меня есть интерфейс (называемый Subject ), который имеет следующий метод: public void addObserver(Observer o); Затем у меня есть другой интерфейс, который расширяет Subject , называемый TimerSubject . Этот интерфейс является более...

Я пытаюсь вернуть наблюдаемое из функции, которая внутренне использует Rx.Subject. Конечно, как и в случае с любым хорошим API, детали реализации должны быть полностью абстрагированы от потребителя. Однако с помощью Subject.asObservable () любой...

У меня есть метод службы, который получает фиктивные данные и возвращает наблюдаемое. private dummySubject = new BehaviorSubject<Dummy>(null); dummy$ = this.dummySubject.asObservable(); loadDummyData(id: string): Observable<Dummy> {...

Я должен обеспечить завершение Observable. Это наблюдение за потоковыми данными, изменение которых не входит в мои обязанности. Потоковые данные могут вообще не тикать. Я столкнулся с использованием предметного члена, который я могу использовать...