RxJava - PublishSubject

RxJava - PublishSubject

PublishSubject emits all the items at the point of subscription. This is the most basic form of Subject

Example

public class RxPublishSubject {       public static void main (String args[])     {         PublishSubject pSubject = PublishSubject.create();         pSubject.onNext(0);         pSubject.subscribe(it -> System.out.println("Observer 1 onNext: " + it),                 (Throwable error) -> { }, () -> {},                 on1 -> System.out.println("Observer 1 onSubscribe"));         pSubject.onNext(1);         pSubject.onNext(2);         pSubject.subscribe(it -> System.out.println("Observer 2 onNext: " + it),                 (Throwable error) -> { }, () -> {},                 on1 -> System.out.println("Observer 2 onSubscribe"));         pSubject.onNext(3);         pSubject.onNext(4);     } }

 

Output

Observer 1 onSubscribe Observer 1 onNext: 1 Observer 1 onNext: 2 Observer 2 onSubscribe Observer 1 onNext: 3 Observer 2 onNext: 3 Observer 1 onNext: 4 Observer 2 onNext: 4

 

RxJava Tutorial RxJava - Environment Setup RxJava’s Characteristics RxJava - How Observable works RxJava - Single Observable RxJava - MayBe Observable RxJava - Completable Observable RxJava - Using CompositeDisposable RxJava - Creating Operators RxJava - Transforming Operators RxJava - Filtering Operators RxJava - Combining Operators RxJava - Utility Operators RxJava - Conditional Operators RxJava - Mathematical Operators RxJava - Subjects RxJava - PublishSubject RxJava - BehaviorSubject RxJava - AsyncSubject RxJava - ReplaySubject RxJava - Schedulers RxJava - Trampoline Scheduler RxJava - NewThread Scheduler RxJava - Computation Scheduler RxJava - IO Scheduler RxJava - From Scheduler RxJava - Buffering