feat: crude implementation of RxBus - uses buffer with tweaked settings

Kaushik Gopal · Kaushik Gopal · commit 6fceaf073016 · 2014-12-24T22:16:38.000-08:00
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
@@ -34,6 +34,7 @@ public void onActivityCreated(@Nullable Bundle savedInstanceState) {
   @OnClick(R.id.btn_demo_rxbus_tap)
   public void onTapButtonClicked() {
     _rxBus.send(new TapEvent());
+
   }
 
   public static class TapEvent {}
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
@@ -12,11 +12,13 @@
 import butterknife.InjectView;
 import com.morihacky.android.rxjava.MainActivity;
 import com.morihacky.android.rxjava.app.R;
+import java.util.List;
 import java.util.concurrent.TimeUnit;
 import rx.Subscription;
 import rx.android.observables.AndroidObservable;
+import rx.android.schedulers.AndroidSchedulers;
 import rx.functions.Action1;
-import rx.schedulers.Schedulers;
+import rx.functions.Func1;
 
 import static com.morihacky.android.rxjava.rxbus.RxBusFrag1.TapEvent;
 
@@ -25,8 +27,10 @@ public class RxBusFrag2
 
   private RxBus _rxBus;
   private Subscription _subscription1_tapListen;
+  private Subscription _subscription2_tapCollector;
 
   @InjectView(R.id.demo_rxbus_tap_txt) TextView _tapEventTxtShow;
+  @InjectView(R.id.demo_rxbus_tap_count) TextView _tapEventCountShow;
 
   @Override
   public View onCreateView(LayoutInflater inflater,
@@ -57,8 +61,17 @@ public void call(Object event) {
           }
         });
 
-    _rxBus.toObserverable().debounce(400, TimeUnit.MILLISECONDS, Schedulers.io()).subscribe();
-
+    _rxBus.toObserverable().buffer(1, TimeUnit.SECONDS).filter(new Func1<List<Object>, Boolean>() {
+      @Override
+      public Boolean call(List<Object> objects) {
+        return objects != null && objects.size() > 0;
+      }
+    }).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<List<Object>>() {
+      @Override
+      public void call(List<Object> taps) {
+        _showTapCount(taps.size());
+      }
+    });
   }
 
   private void _showTapText() {
@@ -67,6 +80,18 @@ private void _showTapText() {
     ViewCompat.animate(_tapEventTxtShow).alphaBy(-1f).setDuration(400);
   }
 
+  private void _showTapCount(int size) {
+    _tapEventCountShow.setText(String.valueOf(size));
+    _tapEventCountShow.setVisibility(View.VISIBLE);
+    _tapEventCountShow.setScaleX(1f);
+    _tapEventCountShow.setScaleY(1f);
+    ViewCompat.animate(_tapEventCountShow)
+        .scaleXBy(-1f)
+        .scaleYBy(-1f)
+        .setDuration(400)
+        .setStartDelay(100);
+  }
+
   @Override
   public void onStop() {
     super.onStop();
diff --git a/app/src/main/res/layout/fragment_rxbus_frag2.xml b/app/src/main/res/layout/fragment_rxbus_frag2.xml
@@ -7,6 +7,7 @@
 
     <TextView
         android:id="@+id/demo_rxbus_tap_count"
+        android:visibility="invisible"
         android:layout_gravity="center"
         android:layout_height="wrap_content"
         android:layout_width="wrap_content"

Original file line number	Diff line number	Diff line change
`@@ -34,6 +34,7 @@ public void onActivityCreated(@Nullable Bundle savedInstanceState) {`
`34`	`34`	`@OnClick(R.id.btn_demo_rxbus_tap)`
`35`	`35`	`public void onTapButtonClicked() {`
`36`	`36`	`_rxBus.send(new TapEvent());`
	`37`	`+`
`37`	`38`	`}`
`38`	`39`
`39`	`40`	`public static class TapEvent {}`