Extracting sub-streams, based on a termination attribute

Question

I have a stream where the events look something like this:

{ 
  endOfSequence : false,
  sequenceId: 12345,
  data: [.....]
}

I need to terminate the sequence when endOfSequence === true. I started with takeWhile:

seq = stream.takeWhile( function(event){
    return !event.endOfSeq;
});

but the problem is that I miss the last event.

I can obviously write code that accomplishes the same thing, for example:

function beforeEnd(event){
    return !event.endOfSeq;
}
seq = stream.takeWhile(beforeEnd)
            .merge(stream.skipWhile(beforeEnd).take(1));

But this is a bit ugly. Is there a better way?

Answer 1

You can write a custom handler with Bacon.withHandler that emits a Bacon.End() when you get the endOfSequence.

seq.withHandler(function(event) {
    var ret = this.push(event)
    if(event.hasValue() && event.value().endOfSequence) {
       ret = this.push(new Bacon.End()) 
    }
    return ret
})

A working example can be found in this jsFiddle.