Это немного странно, но это работает для меня, и я могу импортировать его и использовать.
я RxJS5 конвейер выглядит так
Rx.Observable.from([2, 3, 4, 5, 6])
.takeWhile((v) => { v !== 4 })
Я хочу сохранить подписку, пока не увижу 4, но я хочу, чтобы последний элемент 4 также был включен в результат. Таким образом, приведенный выше пример должен быть
2, 3, 4
Однако согласноофициальный документ, takeWhile Оператор не включительно. Это означает, что когда он встречает элемент, который не соответствует предикату, который мы дали, он завершает поток немедленно без последнего элемента. В результате вышеприведенный код фактически выведет
2, 3
Итак, мой вопрос, как проще всего достичьtakeWhile но также испустить последний элемент с RxJS?