Создание наблюдаемого из подписки?

Question

У меня есть помощник по реактивности не rx js, в котором есть метод .subscribe(). Он соответствует интерфейсу rxjs.Subscribable, но не принадлежит rx js.

Есть ли в rx js утилита для обертывания объекта, подобного наблюдаемому, и создания наблюдаемого?

const nonRxjsSource$ = new NotObserable()

const rxSource$ = rxjs.fromSubscribable(nonRxjsSource$)
rxSource$.pipe(....)

Answer 1

если у него такой же интерфейс для подписки, вы можете создать Subject для перенаправления.

const rxSource=new Subject();
nonRxjsSource$.subscribe(rxSource)