Jul 23, 2017 · 1 min read
Vladimir Chernis Yes the hot publishers start emitting item immediately after they are created.
Example:
Subject<Integer> subject = PublishSubject.create();
subject.onNext(0);
subject.onNext(1);
subject.subscribe(
val -> System.out.println("Subscriber1 received " + val),
err -> System.out.println("error"),
() -> System.out.println("complete"));
subject.onNext(2);
subject.onNext(3);
subject.onComplete();OUTPUT:
Subscriber received 2
Subscriber received 3
complete
