Всей реактивностью как таковой rxjs занимается, думаю стоит изучить саму библиотеку и её принципы, есть много ресурсов по ней от обучающих игр до челенж заданий (скинуть пока не могу но думаю они норм гуглятся)
получается "Подскажите принцип реализации observable(типа from) который будет делать observer.next только когда данные прошли через поток" все равно ничего не понял хD