автономный конкат не возвращает наблюдаемого - PullRequest
Новая
       31

автономный конкат не возвращает наблюдаемого

0 голосов
/ 04 июля 2018

Я пытаюсь понять новые наблюдаемые (rxjs) с точки зрения операторов, допускаемых для таблиц. Для этого у меня есть следующий код 

        const messagesToDispatch = concat(
            of({ type: 'REGITERING_USER' }).delay(5000),
            of({ type: 'REGISTER_USER_COMPLETE', value })
        ).pipe();

        messagesToDispatch.subscribe(subValue => {
            console.log(subValue);
        });

Теперь, когда я запускаю код, я получаю следующую ошибку 

messagesToDispatch.subscribe is not a function

Однако, когда я пытаюсь выполнить следующее, это работает 

    concatMap(value => {
        const messagesToDispatch = Observable.concat(
            of({ type: 'REGITERING_USER' }).delay(5000),
            of({ type: 'REGISTER_USER_COMPLETE', value })
        );

        messagesToDispatch.subscribe(subValue => {
            console.log(subValue);
        });

Обратите внимание, что я использовал Observable.concat вместо concat. Я не уверен, что здесь происходит.

1 Ответ

0 голосов
/ 04 июля 2018

Вам необходимо импортировать concat в RxJS6 следующим образом, если вы хотите запустить свой код без ошибок: 

import {concat, of} from 'rxjs';

const messagesToDispatch = concat(
            of({ type: 'REGITERING_USER' }).pipe(delay(5000)),
            of({ type: 'REGISTER_USER_COMPLETE', value })
        );

Также обратите внимание, как используется pipe.

...