Создаёт событие, которое будет срабатывать при каждом обновлении переданного observable. Применяется для реализации взаимодействия с библиотеками на основе стримов, например rxjs и most

Для обратного действия подписки стримов на юниты эффектора можно воспользоваться методами вроде from из rxjs: юниты эффектора распознаются как сущности, на которые можно подписаться

Формула

function fromObservable(stream: Observable<T>): Event<T>;

Аргументы

1. observable: Observable

Возвращает

Новое событие

Пример

import { interval } from "rxjs";
import { fromObservable } from "effector";

//emit value in sequence every 1 second
const source = interval(1000);

const event = fromObservable(source);

//output: 0,1,2,3,4,5....
event.watch(console.log);