upgrade to rxjava2

Author: Viktor Schmidt

src/main/java/learnrxjava/examples/FlowControlThrottleExample.java

@@ -1,27 +1,29 @@
 package learnrxjava.examples;
 import java.util.concurrent.TimeUnit;
 
-import rx.Observable;
-import rx.Subscriber;
-import rx.schedulers.Schedulers;
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.schedulers.Schedulers;
+
+
 
 public class FlowControlThrottleExample {
 
     public static void main(String args[]) {
         // first item emitted in each time window
-        hotStream().throttleFirst(500, TimeUnit.MILLISECONDS).take(10).toBlocking().forEach(System.out::println);
+        hotStream().throttleFirst(500, TimeUnit.MILLISECONDS).take(10).blockingForEach(System.out::println);
 
         // last item emitted in each time window
-        hotStream().throttleLast(500, TimeUnit.MILLISECONDS).take(10).toBlocking().forEach(System.out::println);
+        hotStream().throttleLast(500, TimeUnit.MILLISECONDS).take(10).blockingForEach(System.out::println);
     }
 
     /**
      * This is an artificial source to demonstrate an infinite stream that emits randomly
      */
     public static Observable<Integer> hotStream() {
-        return Observable.create((Subscriber<? super Integer> s) -> {
+        return Observable.create((ObservableEmitter<Integer> s) -> {
             int i = 0;
-            while (!s.isUnsubscribed()) {
+            while (!s.isDisposed()) {
                 s.onNext(i++);
                 try {
                     // sleep for a random amount of time

src/main/java/learnrxjava/examples/FlowControlWindowExample.java

@@ -2,18 +2,20 @@
 
 import java.util.concurrent.TimeUnit;
 
-import rx.Observable;
-import rx.Subscriber;
-import rx.schedulers.Schedulers;
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.schedulers.Schedulers;
+
+
 
 public class FlowControlWindowExample {
 
     public static void main(String args[]) {
         // buffer every 500ms (using 999999999 to mark start of output)
-        hotStream().window(500, TimeUnit.MILLISECONDS).take(10).flatMap(w -> w.startWith(999999999)).toBlocking().forEach(System.out::println);
+        hotStream().window(500, TimeUnit.MILLISECONDS).take(10).flatMap(w -> w.startWith(999999999)).blockingForEach(System.out::println);
 
         // buffer 10 items at a time (using 999999999 to mark start of output)
-        hotStream().window(10).take(2).flatMap(w -> w.startWith(999999999)).toBlocking().forEach(System.out::println);
+        hotStream().window(10).take(2).flatMap(w -> w.startWith(999999999)).blockingForEach(System.out::println);
 
         System.out.println("Done");
     }
@@ -22,8 +24,8 @@ public static void main(String args[]) {
      * This is an artificial source to demonstrate an infinite stream that bursts intermittently
      */
     public static Observable<Integer> hotStream() {
-        return Observable.create((Subscriber<? super Integer> s) -> {
-            while (!s.isUnsubscribed()) {
+        return Observable.create((ObservableEmitter<Integer> s) -> {
+            while (!s.isDisposed()) {
                 // burst some number of items
                 for (int i = 0; i < Math.random() * 20; i++) {
                     s.onNext(i);