From 0f6dd0c92fbcaa070a136cbc9f5a46d3b5db7ebb Mon Sep 17 00:00:00 2001
From: Marcin Kunert <the.martines@gmail.com>
Date: Sun, 27 Nov 2016 23:18:32 +0100
Subject: [PATCH] Updated buffer demo to RxJava2

---
 .../rxjava/fragments/BufferDemoFragment.java  | 21 ++++++++++---------
 1 file changed, 11 insertions(+), 10 deletions(-)

diff --git a/app/src/main/java/com/morihacky/android/rxjava/fragments/BufferDemoFragment.java b/app/src/main/java/com/morihacky/android/rxjava/fragments/BufferDemoFragment.java
index d52e3571..445aa735 100644
--- a/app/src/main/java/com/morihacky/android/rxjava/fragments/BufferDemoFragment.java
+++ b/app/src/main/java/com/morihacky/android/rxjava/fragments/BufferDemoFragment.java
@@ -20,9 +20,10 @@
 
 import butterknife.Bind;
 import butterknife.ButterKnife;
-import rx.Observer;
-import rx.Subscription;
-import rx.android.schedulers.AndroidSchedulers;
+import hu.akarnokd.rxjava.interop.RxJavaInterop;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.observers.DisposableObserver;
 import timber.log.Timber;
 
 /**
@@ -48,18 +49,18 @@ public class BufferDemoFragment
     private LogAdapter _adapter;
     private List<String> _logs;
 
-    private Subscription _subscription;
+    private Disposable _disposable;
 
     @Override
     public void onResume() {
         super.onResume();
-        _subscription = _getBufferedSubscription();
+        _disposable = _getBufferedDisposable();
     }
 
     @Override
     public void onPause() {
         super.onPause();
-        _subscription.unsubscribe();
+        _disposable.dispose();
     }
 
     @Override
@@ -85,8 +86,8 @@ public View onCreateView(LayoutInflater inflater,
     // -----------------------------------------------------------------------------------
     // Main Rx entities
 
-    private Subscription _getBufferedSubscription() {
-        return RxView.clickEvents(_tapBtn)
+    private Disposable _getBufferedDisposable() {
+        return  RxJavaInterop.toV2Observable(RxView.clickEvents(_tapBtn))
               .map(onClickEvent -> {
                   Timber.d("--------- GOT A TAP");
                   _log("GOT A TAP");
@@ -94,10 +95,10 @@ private Subscription _getBufferedSubscription() {
               })
               .buffer(2, TimeUnit.SECONDS)
               .observeOn(AndroidSchedulers.mainThread())
-              .subscribe(new Observer<List<Integer>>() {
+              .subscribeWith(new DisposableObserver<List<Integer>>() {
 
                   @Override
-                  public void onCompleted() {
+                  public void onComplete() {
                       // fyi: you'll never reach here
                       Timber.d("----- onCompleted");
                   }