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.
var first = stream.firstOrError()and
var rest = stream.skip(1). Then I do
first.map(f -> someFunction(f, rest)). But when the first is done with that first element it cancels the rest of the
streamwhich seems to hang up on
rest. This is when using
reactive-grpc... (I don't seem to be able to reproduce it using
Flowable.justtype tests even though cancel is called inside rxjava). is there a way to multiplex a stream like this?