monio
monio copied to clipboard
IOxHelpers: research and provide additional operators
RX operators to look more into adding in IOxHelpers:
buffer(..)-- mostly the time based one, which is sorta zip-over-timetakeUntil(..)-- waits on a value from another IOx to signal it should stop takingrange(start,end)-- likeseq(start,1)+take(end - start)forkJoin(..)-- likezip(..)but waits to emit only the last set of valuesconcat(..)-- combinator (likemerge(..)orzip(..), but goes in order)... would need a different name!pluck(..)-- like IOx's version ofprop(..)find(..)-- likefilterIn(..)+take(1)timeout(..)