Я совсем новичок в RxJava
. Сейчас я пробую RxAndroidBle и сравниваю его с реализацией Android API для BLE. Мое периферийное устройство отправляет сразу много notifications
(около 30 КБ фрагментами по 512 байт). В Rx их получение занимает около 10-12 секунд. Когда я пытаюсь использовать Android API, это около 2-3 секунд.
В моей реализации RxAndroidBle я делаю так, как это предлагается в примере приложения:
connectionObservable
.flatMap(rxBleConnection -> rxBleConnection.setupNotification(UUID.fromString(mCharacteristicUUID)))
.doOnNext(notificationObservable -> runOnUiThread(this::notificationHasBeenSetUp))
.flatMap(notificationObservable -> notificationObservable)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
this::onNotificationReceived,
this::onNotificationSetupFailure
);
Есть ли способ сделать это быстрее?