0
私はRxJavaの新しいバージョンです。rxandroidbleライブラリーのデモを読むと、なぜ最初のブロッカーが切断されるのか不思議です。ストリームが完了していない間のみ、単一の値が、放出されることestablishConnection()
状態、のなぜ最初にメソッドを呼び出すと、ディスカバリー後に自動的に切断されるのですか?
@OnClick(R.id.connect)
public void onConnectToggleClick() {
bleDevice.establishConnection(false)
.flatMap(RxBleConnection::discoverServices)
.first() // Disconnect automatically after discovery
.compose(bindUntilEvent(PAUSE))
.observeOn(AndroidSchedulers.mainThread())
.doOnUnsubscribe(this::updateUI)
.subscribe(adapter::swapScanResult, this::onConnectionFailure);
updateUI();
}