feat: add RxBus and singleton instantiation in all fragments

Kaushik Gopal · Kaushik Gopal · commit 77a8537862b9 · 2014-12-24T15:03:22.000-08:00
diff --git a/app/src/main/java/com/morihacky/android/rxjava/MainActivity.java b/app/src/main/java/com/morihacky/android/rxjava/MainActivity.java
@@ -3,12 +3,15 @@
 import android.os.Bundle;
 import android.support.v4.app.FragmentActivity;
 import com.morihacky.android.rxjava.app.R;
+import com.morihacky.android.rxjava.rxbus.RxBus;
 import com.morihacky.android.rxjava.rxbus.RxBusDemoFragment;
 import timber.log.Timber;
 
 public class MainActivity
     extends FragmentActivity {
 
+  private RxBus _rxBus = null;
+
   @Override
   protected void onCreate(Bundle savedInstanceState) {
     super.onCreate(savedInstanceState);
@@ -18,7 +21,15 @@ protected void onCreate(Bundle savedInstanceState) {
 
     getSupportFragmentManager().beginTransaction().addToBackStack(this.toString())
         //.replace(R.id.activity_main, new MainFragment(), this.toString())
-        .replace(R.id.activity_main, new RxBusDemoFragment(), this.toString())
-        .commit();
+        .replace(R.id.activity_main, new RxBusDemoFragment(), this.toString()).commit();
+  }
+
+  // This is better done with a DI Library like Dagger
+  public RxBus getRxBusSingleton() {
+    if (_rxBus == null) {
+      _rxBus = new RxBus();
+    }
+
+    return _rxBus;
   }
 }
diff --git a/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBus.java b/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBus.java
@@ -0,0 +1,27 @@
+package com.morihacky.android.rxjava.rxbus;
+
+import rx.Observable;
+import rx.subjects.PublishSubject;
+import rx.subjects.SerializedSubject;
+import rx.subjects.Subject;
+
+/**
+ * courtesy: https://gist.github.com/benjchristensen/04eef9ca0851f3a5d7bf
+ */
+public class RxBus {
+
+  //private final PublishSubject<Object> _bus = PublishSubject.create();
+
+  // If multiple threads are going to emit events to this
+  // then it must be made thread-safe like this instead
+  private final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create());
+
+  public void send(Object o) {
+    _bus.onNext(o);
+  }
+
+  public Observable<Object> toObserverable() {
+    return _bus;
+  }
+}
+
diff --git a/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag1.java b/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag1.java
@@ -7,11 +7,14 @@
 import android.view.View;
 import android.view.ViewGroup;
 import butterknife.ButterKnife;
+import com.morihacky.android.rxjava.MainActivity;
 import com.morihacky.android.rxjava.app.R;
 
 public class RxBusFrag1
     extends Fragment {
 
+  private RxBus _rxBus;
+
   @Override
   public View onCreateView(LayoutInflater inflater,
                            @Nullable ViewGroup container,
@@ -20,4 +23,10 @@ public View onCreateView(LayoutInflater inflater,
     ButterKnife.inject(this, layout);
     return layout;
   }
+
+  @Override
+  public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    _rxBus = ((MainActivity) getActivity()).getRxBusSingleton();
+  }
 }
diff --git a/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag2.java b/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag2.java
@@ -7,11 +7,14 @@
 import android.view.View;
 import android.view.ViewGroup;
 import butterknife.ButterKnife;
+import com.morihacky.android.rxjava.MainActivity;
 import com.morihacky.android.rxjava.app.R;
 
 public class RxBusFrag2
     extends Fragment {
 
+  private RxBus _rxBus;
+
   @Override
   public View onCreateView(LayoutInflater inflater,
                            @Nullable ViewGroup container,
@@ -20,4 +23,10 @@ public View onCreateView(LayoutInflater inflater,
     ButterKnife.inject(this, layout);
     return layout;
   }
+
+  @Override
+  public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    _rxBus = ((MainActivity) getActivity()).getRxBusSingleton();
+  }
 }
diff --git a/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag3.java b/app/src/main/java/com/morihacky/android/rxjava/rxbus/RxBusFrag3.java
@@ -7,11 +7,14 @@
 import android.view.View;
 import android.view.ViewGroup;
 import butterknife.ButterKnife;
+import com.morihacky.android.rxjava.MainActivity;
 import com.morihacky.android.rxjava.app.R;
 
 public class RxBusFrag3
     extends Fragment {
 
+  private RxBus _rxBus;
+
   @Override
   public View onCreateView(LayoutInflater inflater,
                            @Nullable ViewGroup container,
@@ -20,4 +23,10 @@ public View onCreateView(LayoutInflater inflater,
     ButterKnife.inject(this, layout);
     return layout;
   }
+
+  @Override
+  public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+    super.onActivityCreated(savedInstanceState);
+    _rxBus = ((MainActivity) getActivity()).getRxBusSingleton();
+  }
 }
