fix: MissingBackpressureException

ievolution · Jan 9, 2020 · 22b8277 · 22b8277
1 parent a2bd97d
commit 22b8277
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/android/src/main/java/com/polidea/reactnativeble/BleModule.java b/android/src/main/java/com/polidea/reactnativeble/BleModule.java
@@ -63,6 +63,7 @@
 import rx.Observable;
 import rx.Observer;
 import rx.Subscription;
+import rx.schedulers.Schedulers;
 import rx.functions.Action0;
 import rx.functions.Action1;
 import rx.functions.Func0;
@@ -1332,6 +1333,8 @@ public Observable<byte[]> call(Observable<byte[]> observable) {
                         return observable;
                     }
                 })
+                .onBackpressureBuffer()
+                .observeOn(Schedulers.computation())
                 .doOnUnsubscribe(new Action0() {
                     @Override
                     public void call() {

diff --git a/package-lock.json b/package-lock.json