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.
PublishSubject.create<T>()so far, and it works well. However, now I want to push a value upon each subscription. I found
PublishSubject.create(Observable.OnSubscribe<T> f), which allows me to specify an OnSubscribe-function. But this one returns an
Observableinstead of a
PublishSubject, so I can't use
onNextanymore. How can I go about this?