Skip to content

Instantly share code, notes, and snippets.

@anitaa1990
Created December 3, 2018 11:53
Show Gist options
  • Save anitaa1990/ee9fad35f2e27c7bdf36d32bfda9a47e to your computer and use it in GitHub Desktop.
Save anitaa1990/ee9fad35f2e27c7bdf36d32bfda9a47e to your computer and use it in GitHub Desktop.
ReplaySubject<Integer> pSubject = ReplaySubject.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);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment