RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Hi guys!
(and girls)
I'm new here and in the Rx(Java/Swift) world, and I have a very dummy question :)
I want to create a PublishSubject, but how can I, upon declaration, specify actions that should be done when an observer subscribes, or when the subject gets disposed?
I want to create a PublishSubject, but how can I, upon declaration, specify actions that should be done when an observer subscribes, or when the subject gets disposed?
Thanks!
Mostly the disposing part
I tried this:
BehaviorSubject<T> valueSubject = (BehaviorSubject<T>) BehaviorSubject.create(new ObservableOnSubscribe<T>() {
@Override
public void subscribe(ObservableEmitter<T> emitter) throws Exception {
// do something here
}
});
But I got a
io.reactivex.internal.operators.observable.ObservableCreate cannot be cast to io.reactivex.subjects.BehaviorSubject
I'm feeling it isn't the right approach
Have you tried googling it? https://blog.mindorks.com/understanding-rxjava-subject-publish-replay-behavior-and-async-subject-224d663d452f
I don't know how to respond to that
Based on your question, you should read a bit about RxJava and Subjects first.
That is what I have been doing and am currently doing, I just thought I could find some help here, my bad
Thank you anyway
Subjects are self-contained components of RxJava and you can only create them via their own
Based on the misunderstanding your question implies, I wanted to encourage you to familiarize yourself with the concepts and components of RxJava first, so the answer, which invokes more concepts and components, can be understood better. For this, I suggest reading Learning RxJava.
create method. create(ObservableOnSubscribe) is defined on Observable which creates an Observable, a cold source and will have nothing to do with the subject type. Many operators in RxJava are named after the behavior they do in an everyday language, such as "actions done when an observer subscribes" -> doOnSubscribe, when the subscription gets disposed: doOnDispose. Subjects themselves are not disposed.Based on the misunderstanding your question implies, I wanted to encourage you to familiarize yourself with the concepts and components of RxJava first, so the answer, which invokes more concepts and components, can be understood better. For this, I suggest reading Learning RxJava.
Thank you David, that helped a lot