takeWhileInclusive?

[raimohanska]

Should we add an inclusive version of takeWhile? I think this would have come handy a few times. There's a related StackOverflow question: http://stackoverflow.com/questions/27114089/extracting-sub-streams-based-on-a-termination-attribute

[semmel]

Just stumbled over this ancient issue, while pondering what the reason is that obs.takeWhile(valve) does not end when valve becomes false but only on the following obs event...?

Anyway, I find takeWhileInclusive valuable and have used my own related function:

takeUntilLastEventSatisfies = (predicate, observable) =>
    observable.transform(
        (baconEvent, sink) => {
            if (!Bacon.hasValue(baconEvent)) {// error or end
                return sink(baconEvent);
            }
                
            if (predicate(baconEvent.value)) {
                sink(baconEvent);
                return sink(new Bacon.End());
            }
                
            return sink(baconEvent);
        })
    );