Я новичок в наблюдаемых и пытаюсь обернуться вокруг многоадресной рассылки и операторов. Я использую fromEvent
, который является многоадресной наблюдаемой (как я узнал). Я пытаюсь создать пользовательский оператор, но пользовательский оператор возвращает наблюдаемое, которое является одноадресным.
fromEvent(document, 'readystatechange') // Multicasted
.pipe(
myCustomOperator() // This will return another observable which is unicasted
);
Я хочу сохранить автоматическое подключение многоадресного поведения fromEvent
после оператора pipe
. Как мне это сделать?