the use case is I open a stream and takeWhile for...

# rx

[ursus]

the use case is I open a stream and takeWhile for X seconds + reduce it, so when takeWhile completes the stream I emit that "result" value