Skip to content

Instantly share code, notes, and snippets.

@anitaa1990
Last active December 3, 2018 11:48
Show Gist options
  • Save anitaa1990/beefc2f31d9d18067e38e536c7b74b02 to your computer and use it in GitHub Desktop.
Save anitaa1990/beefc2f31d9d18067e38e536c7b74b02 to your computer and use it in GitHub Desktop.
BehaviorSubject<Integer> pSubject = BehaviorSubject.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