These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
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?
yourPublisher.scan('b', (s, v) -> if (v == 'a' || v == 'b' || s != 'a') v else s).filter(v -> v != 'a' && v != 'b');