Все упомянутое ниже относится к библиотеке RxJS.
Первый AnonymousSubject
нигде не задокументирован.Но есть четкий пример его использования в самой библиотеке (WebSocketSubject
).Как видно из кода, AnonymousSubject
создает двунаправленный поток.
Теперь проблема в том, что мне нужен похожий предмет, но который будет иметь разные типы входов и выходов, чтобы подписчики и наблюдатели могли получать разные типы данных.Вы можете увидеть похожую проблему здесь # 2602 .И в настоящее время в TypeScript невозможно расширить классы Subject
или AnonymousSubject
, чтобы получить эту функциональность, потому что метод next
будет несовместим с его родительским классом.
Мой вариант использования создает что-то похожее на WebSocketSubject
но для сервера WebSocket, так что подписчики субъекта получат Object с сокетом и сообщением, но метод next
будет передавать только сообщение всем сокетам.