composelet's you apply operators without leaving the fluent style of specifying operators. It takes a transformer function that is called with the assembled stream that far and should return a new stream with added operators/behavior.
new Pair(source.take(at), source.skip(at)), wouldn't that subscribe to
It relates to removing repeated regions from a stream of data. TakeUntil won't work since it stops the stream after the first sentinal value and I just want to filter out data between every pair of sentinal values.
Any ideas how to do this in RX?