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.
@akarnokd I guess I was misreading it.
This paragraph I think is the one you are refering to
In the fresh state, consumers can pile up and be ready to receive events. An atomic state change to running will begin streaming events until a terminal event is reached. Consumers subscribing in this state will always receive the terminal event, and in case of replay, the cached items as well.
And I'm guessing the "this state" in the final sentence is referring to the terminal state and not the running state, correct?