These are chat archives for ReactiveX/RxJava

3rd
Jan 2017
Connor Lanigan
@connorlanigan
Jan 03 2017 10:50
I'm trying to create an Observable where I can dynamically push new values. For this, I'm using 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 Observable instead of a PublishSubject, so I can't use onNext anymore. How can I go about this?