createResumeStateObservable => backpressure handling added

Michael Flisar · Michael Flisar · commit ea0e3c060285 · 2016-05-03T17:32:56.000+02:00
diff --git a/lib/src/main/java/com/michaelflisar/rxbus/rx/RXUtil.java b/lib/src/main/java/com/michaelflisar/rxbus/rx/RXUtil.java
@@ -76,7 +76,7 @@ public void onResumedChanged(boolean resumed) {
 
                 provider.addResumedListener(resumedListener, false);
             }
-        });
+        }).onBackpressureBuffer();
     }
 
     public static <T> boolean safetyQueueCheck(T event, IRXBusIsResumedProvider isResumedProvider)

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ public void onResumedChanged(boolean resumed) {`
`76`	`76`
`77`	`77`	`provider.addResumedListener(resumedListener, false);`
`78`	`78`	`}`
`79`		`- });`
	`79`	`+ }).onBackpressureBuffer();`
`80`	`80`	`}`
`81`	`81`
`82`	`82`	`public static <T> boolean safetyQueueCheck(T event, IRXBusIsResumedProvider isResumedProvider)`