Intro-To-RxJava
Intro-To-RxJava copied to clipboard
Froussios
An extensive tutorial on RxJava
In Part 3 in the [Encapsulating With asObservable](https://github.com/Froussios/Intro-To-RxJava/blob/259e1fe27999387780752c3d96247ea2a9ae7122/Part%203%20-%20Taming%20the%20sequence/1.%20Side%20effects.md#encapsulating-with-asobservable) section you use asObservable() which is no longer used. See [What's different in 2.0](https://github.com/ReactiveX/RxJava/wiki/What%27s-different-in-2.0) specifically in the [Instance methods section](https://github.com/ReactiveX/RxJava/wiki/What%27s-different-in-2.0#instance-methods) where it...
The code example for the filter operator filters out odd numbers leaving only even numbers. However the text description of it suggests it does the opposite. This PR corrects the...
Fixed result output in method exampleMutlicast(), made some improvements.
Fixed result output for method exampleRefcount(), also little bit improved.
Hi, Please check the code example [here](https://github.com/Froussios/Intro-To-RxJava/blob/master/Part%203%20-%20Taming%20the%20sequence/6.%20Hot%20and%20Cold%20observables.md#disconnecting): ``` java ConnectableObservable connectable = Observable.interval(200, TimeUnit.MILLISECONDS).publish(); Subscription s = connectable.connect(); connectable.subscribe(i -> System.out.println(i)); Thread.sleep(1000); System.out.println("Closing connection"); s.unsubscribe(); Thread.sleep(1000); System.out.println("Reconnecting"); s = connectable.connect();...
