Регистрация подписки на обратный звонок в Redux Observable

Question

thirdPartyApiWithCallbackSubscription продолжает возвращать новые данные, когда я пытался в консоли Chrome в режиме обещания.Теперь я хочу переместить его в Observable и продолжать подписку по всему миру.Но в наблюдаемом режиме он просто возвращает данные один раз.Как мне выполнить рефакторинг кода, чтобы он продолжал получать данные при поступлении новых данных?

Observable.create(observer => {
  thirdPartyApiWithCallbackSubscription(data => {
    observer.next(data);
  });
})
.pipe(
  map(data => {
    return { type: 'DATA_CHANGED', payload: data };
  })
);

Answer 1

Только что подтверждено thirdPartyApiWithCallbackSubscription есть проблемы, описанный выше метод работает так, как я ожидал. Благодаря.