feat: got basic logging working with RxJava (no accumulation yet)

Kaushik Gopal · Kaushik Gopal · commit 657bcfc79413 · 2014-07-23T00:37:21.000-07:00
diff --git a/app/src/main/java/com/morihacky/android/rxjava/DemoAccumulateEventFragment.java b/app/src/main/java/com/morihacky/android/rxjava/DemoAccumulateEventFragment.java
@@ -18,39 +18,118 @@
 import butterknife.ButterKnife;
 import butterknife.InjectView;
 import butterknife.OnClick;
+import rx.Observable;
+import rx.Observer;
+import rx.android.observables.AndroidObservable;
+import rx.android.schedulers.AndroidSchedulers;
+import rx.functions.Action1;
+import rx.schedulers.Schedulers;
+import rx.subjects.BehaviorSubject;
+import timber.log.Timber;
 
 public class DemoAccumulateEventFragment
-    extends Fragment {
+    extends Fragment
+    implements Observer<Integer> {
 
     @InjectView(R.id.accumulated_event_list) ListView _logsListView;
 
     private LogAdapter _adapter;
     private List<String> _logs;
 
-    @Override
-    public View onCreateView(LayoutInflater inflater,
-                             @Nullable ViewGroup container,
-                             @Nullable Bundle savedInstanceState) {
-        View layout = inflater.inflate(R.layout.fragment_accumulate, container, false);
-        ButterKnife.inject(this, layout);
-        return layout;
-    }
+    private BehaviorSubject<Observable<Integer>> _loggerSubject;            // Special Rx entity that modifies Observable behavior for aggregation
+    private int _counter = 0;
 
     @Override
     public void onActivityCreated(@Nullable Bundle savedInstanceState) {
         super.onActivityCreated(savedInstanceState);
         _setupLogAdapter();
+
+        // Create the subscription
+        AndroidObservable.bindFragment(this, _getObservable_ForTaps())     // Observable
+            .observeOn(AndroidSchedulers.mainThread())
+            .subscribeOn(Schedulers.io())
+            .subscribe(_getSubscriber_ForTaps());                          // Subscriber
     }
 
+
     @OnClick(R.id.accumulated_event_btn)
     public void onButtonTapped() {
+        // BehaviorSubject takes in Observable inputs.
+        // So send 1 tap as an observable
+        _loggerSubject.onNext(Observable.from(1));
+    }
+
+    // -----------------------------------------------------------------------------------
+    // Main Rx entities
+
+    /**
+     * Gets the Observable as emitted from BehaviorSubject
+     *
+     * It begins by emitting the item most recently emitted by source Observable
+     * (or seed/default if none has yet been emitted - which is the case here)
+     *
+     * https://github.com/Netflix/RxJava/wiki/Subject#behaviorsubject
+     */
+    private Observable<Integer> _getObservable_ForTaps() {
+        if (_loggerSubject == null) {
+            _loggerSubject = BehaviorSubject.create(Observable.from(0));
+        }
+
+        return Observable.switchOnNext(_loggerSubject);
+    }
 
-        _addLogToAdapter("Tapped");
+    /**
+     * Subscriber that has the 3 important actions
+     * 1. onNext
+     * 2. onError
+     * 3. onCompleted
+     */
+    private Observer<? super Integer> _getSubscriber_ForTaps() {
+        return this;
+    }
+
+    /*private Action1<Integer> _getSubscriber_ForTaps() {
+        return new Action1<Integer>(){
+
+
+            @Override
+            public void call(Integer integer) {
+
+            }
+        };
+    }*/
+
+
+    @Override
+    public void onCompleted() {
+        Timber.d("--------- completed ");
+        _addLogToAdapter(String.format("%d taps", _counter));
+        _counter = 0;
+    }
+
+    @Override
+    public void onNext(Integer integer) {
+        _counter += integer;
+        onCompleted();
+    }
+
+    @Override
+    public void onError(Throwable e) {
+        Timber.e(e, "--------- Woops something went wrong");
     }
 
     // -----------------------------------------------------------------------------------
     // Method that help wiring up the example (irrelevant to RxJava)
 
+    @Override
+    public View onCreateView(LayoutInflater inflater,
+                             @Nullable ViewGroup container,
+                             @Nullable Bundle savedInstanceState) {
+        View layout = inflater.inflate(R.layout.fragment_accumulate, container, false);
+        ButterKnife.inject(this, layout);
+        return layout;
+    }
+
     private void _setupLogAdapter() {
         _logs = new ArrayList<String>();
         _adapter = new LogAdapter(getActivity(), new ArrayList<String>());
diff --git a/app/src/main/java/com/morihacky/android/rxjava/DemoActivity.java b/app/src/main/java/com/morihacky/android/rxjava/DemoActivity.java
@@ -5,13 +5,18 @@
 
 import com.morihacky.android.rxjava.app.R;
 
+import timber.log.Timber;
+
 public class DemoActivity
     extends FragmentActivity {
 
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_demo);
+
+        Timber.plant(new Timber.DebugTree());
+
         getSupportFragmentManager().beginTransaction()
                                    .addToBackStack(this.toString())
                                    .replace(R.id.activity_container, new DemoFragment(), this.toString())
