Replaced RxJava1 RxRelay with RxJava2 version

ravikumar-n · Kaushik Gopal · commit 9877c7fe2abf · 2017-01-23T07:41:47.000-08:00
diff --git a/app/build.gradle b/app/build.gradle
@@ -51,7 +51,7 @@ dependencies {
     compile "com.github.akarnokd:rxjava2-interop:0.6.1"
 
     compile 'io.reactivex:rxjava-math:1.0.0'
-    compile 'com.jakewharton.rxrelay:rxrelay:1.2.0'
+    compile 'com.jakewharton.rxrelay2:rxrelay:2.0.0'
     compile 'com.jakewharton.rxbinding:rxbinding:0.2.0'
     compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'
 
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
@@ -1,24 +1,24 @@
 package com.morihacky.android.rxjava.rxbus;
 
-import com.jakewharton.rxrelay.PublishRelay;
-import com.jakewharton.rxrelay.Relay;
-import hu.akarnokd.rxjava.interop.RxJavaInterop;
+import com.jakewharton.rxrelay2.PublishRelay;
+import com.jakewharton.rxrelay2.Relay;
+
+import io.reactivex.BackpressureStrategy;
 import io.reactivex.Flowable;
 
 /**
  * courtesy: https://gist.github.com/benjchristensen/04eef9ca0851f3a5d7bf
  */
 public class RxBus {
 
-    private final Relay<Object, Object> _bus = PublishRelay.create().toSerialized();
+    private final Relay<Object> _bus = PublishRelay.create().toSerialized();
 
     public void send(Object o) {
-        _bus.call(o);
+        _bus.accept(o);
     }
 
     public Flowable<Object> asFlowable() {
-        // this won't be necessary after https://github.com/JakeWharton/RxRelay/pull/20 is complete
-        return RxJavaInterop.toV2Flowable(_bus.asObservable());
+        return _bus.toFlowable(BackpressureStrategy.LATEST);
     }
 
     public boolean hasObservers() {
