Многоадресный оператор с конвейером в RxJS 5.5+

Question

Как мне использовать оператор multicast() с новым рекомендуемым подходом в RxJS 5.5 с использованием pipe() вместо операторов цепочки? Я получаю ошибку TypeScript, когда пытаюсь использовать connect(), как я делал раньше:

const even$ = new Subject();

const connectedSub = interval(500)
    .pipe(
        filter(count => count % 2 === 0),
        take(5),
        multicast(even$)
    )
    .connect();

even$.subscribe(value => console.log(value));

Этот код работает, но выдает ошибку TypeScript, которая сообщает, что Property 'connect' does not exist on type 'Observable<{}>'. Использую ли я подключаемые наблюдаемые так, как я должен быть в RxJS 5.5 +?

Answer 1

Текущие - v5.5.10 и v6.1.0 - наборы для pipe не знают о подклассах Observable, поэтому я использую утверждение типа, например:

const connectedObs = interval(500).pipe(
    filter(count => count % 2 === 0),
    take(5),
    multicast(even$)
) as ConnectableObservable<number>;
const connectedSub = connectedObs.connect();