I don't know if RxJS has run out of fashion, but that would give you observable js using map/filter/reduce etc.