RxAndroidBle - долго писать и слушать характеристика уведомления

Я новичок в области android / BLE. Я пытаюсь написать характеристику и прослушать уведомление с помощью библиотеки RxAndroidBle. Я просмотрел множество реализаций, которые кажутся достаточно разными, чтобы мой сценарий работал должным образом. Это сообщение: Нет данных уведомления в настройке записи / уведомления - это почти то, что мне нужно, однако, когда я использую опубликованный код, я не могу захватить какие-либо данные на моем периферийном устройстве, которое, в свою очередь, не возвращает ответ, поскольку я не отправляю ответ. Когда я переключаюсь на построитель длинной записи, я могу писать на свое периферийное устройство и видеть поток данных, но после получения ответа от моего периферийного устройства в моей подписке на уведомления ничего не фиксируется.

Вот мой код:

 private void writeNotify(RxBleDevice peripheral, byte[] payload) {
    Disposable connectionSubscription = peripheral.establishConnection(false)
            .flatMap( // when the connection is available...
                    rxBleConnection -> rxBleConnection.setupNotification(UUID.fromString(notifyCharacteristic)), // ... setup the notification...
                    (rxBleConnection, notifyObservable) -> Observable.combineLatest( // ... when the notification is setup...
                            rxBleConnection.createNewLongWriteBuilder().setBytes(payload).setCharacteristicUuid(UUID.fromString(writecharateristic)).setMaxBatchSize(20).build(), // ... write the characteristic...
                            //rxBleConnection.writeCharacteristic(UUID.fromString(writecharateristic), payload).toObservable(), // ... write the characteristic...
                            notifyObservable, // ... and observe for the first notification on the AP_SCAN_DATA
                            (writtenBytes, responseBytes) -> responseBytes
                    )
            )
            .flatMap(observable -> observable) // ... flatMap the result as it is Observable<byte[]>...// ... and finish after first response is received to cleanup notifications
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(
                    responseBytes -> {
                        String data = new String(responseBytes);
                    },
                    throwable -> {

                    }
            );
}

По отдельности я попытался обработать это как две операции, в которых я настраивал свои характеристики уведомлений после длительной записи на периферийное устройство. Где я подписываюсь на метод ObserverConnectionStateChanges на моем периферийном устройстве и жду, пока сработает состояние отключения, прежде чем настраивать свою характеристику уведомления. В этом сценарии я действительно могу получать частичные ответы, поэтому я знаю, что функция уведомления работает. Я просто не правильно это реализую. Какие-либо предложения?