我正在尝试实现这个写入/通知处理的示例(使用RxAndroidBle,我如何订阅从写入特征的响应?(。
connectionObservable
.flatMap((Function<RxBleConnection, Observable<Observable<byte[]>>>)
(RxBleConnection rxBleConnection) -> {
return rxBleConnection.setupNotification(TX_CHAR_UUID);
},
(BiFunction<RxBleConnection, Observable<byte[]>, Observable<byte[]>>)
(rxBleConnection, apScanDataNotificationObservable) -> {
return Observable.combineLatest(
rxBleConnection.writeCharacteristic(RX_CHAR_UUID, getInputBytes()),
apScanDataNotificationObservable.first(),
new BiFunction<byte[], byte[], byte[]>() {
@Override
public byte[] apply(byte[] writtenBytes, byte[] responseBytes) throws Exception {
return responseBytes;
}
}
);
}
).flatMap(new Function<Observable<byte[]>, Observable<byte[]>>() {
@Override
public Observable<byte[]> apply(Observable<byte[]> observable) throws Exception {
return observable;
}
})
.first()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<byte[]>() {
@Override
public void accept(byte[] bytes) throws Exception {
Log.i("Ivan1", "notification response...." + bytes.toString());
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Log.i("Ivan", "notification response...." + throwable.toString());
}
});
我尝试使用 rxjava1 和 rxjava2 编写,但在这两种情况下,我都遇到了 apScanDataNotificationObservable.first(( 的编译时错误。它说"可观察性中的第一个(字节[](不能应用于(("。所以我不知道我应该传递给第一种方法什么参数。
您收到此错误的原因是原始答案是为RxAndroidBle
的RxJava1
版本提供的,并且您至少在上面的示例中使用了RxJava2
。
在RxJava1
和RxJava2
之间,方法Observable.first()
更改了签名和实现。RxJava2
的等效函数是Observable.take(int count)
您应该更改此行:
apScanDataNotificationObservable.first(),
对此:
apScanDataNotificationObservable.take(1),
此外,Observable.combineLatest()
接受两个Observable
参数,其中rxBleConnection.writeCharacteristic()
是Single
。您应该更改此行:
rxBleConnection.writeCharacteristic(RX_CHAR_UUID, getInputBytes()),
对此:
rxBleConnection.writeCharacteristic(RX_CHAR_UUID, getInputBytes()).toObservable(),