取消訂閱的問題

Question

我正在做一個應用程序，用作使用RxAndroidBle的呼吸機的遙控器。我與unsubscribe一個問題，因爲當我使用

.flatMap(rxBleConnection -> rxBleConnection.writeCharacteristic(Uuids.UUID_RX, flaktCommandConcat.getBytes())) 

，之後我用subscription.unsubscribe(); doesn't工作writeCharacteristics因爲unsubscribe運行總是先和數據之前的連接disconect發送。

我需要的是：

• 當我點擊我要連接呼吸機
• 的按鈕，然後將所有值
• 然後斷開連接。
• 如果我重複這個過程，它將需要一遍又一遍地做同樣的事情。

有人能幫我一些想法嗎？我試圖使用.delay(1000, Time.MILISECONDS)，它工作，但需要很長時間才能將信息發送到呼吸機。

這是我的代碼：

public void writeRxCharacteristics(String flaktCommandConcat){ 

    rxBleDevice = rxBleClient.getBleDevice(Uuids.DEVICE_ADDRESS); 


    subscription = rxBleDevice.establishConnection(true) //false 
      .observeOn(AndroidSchedulers.mainThread()) 
      .flatMap(rxBleConnection -> rxBleConnection.createNewLongWriteBuilder() 
      .setCharacteristicUuid(Uuids.UUID_RX) 
      .setBytes(flaktCommandConcat.getBytes()) 
      .build()) 

      .subscribe(
        byteArray -> { 
         Log.d("CharacteristicValue","WRITE: " + Arrays.toString(byteArray)); 
        }, 

        throwable -> { 
         Log.d("CharacteristicValue","Throwable: " + throwable.toString()); 
         rxBleActivity.onScanFailure(throwable, getContext()); 
        } 
      ); 


    rxBleDevice.observeConnectionStateChanges() 
      .observeOn(AndroidSchedulers.mainThread()) 
      .delay(1000, TimeUnit.MILLISECONDS) 
      .subscribe(
        rxBleConnectionState -> { 
         Log.d("RxBleConnectionState", " CON_STATUS: " + rxBleConnectionState); 
         disconnect(); 

        }, 
        throwable -> { 
         Log.d("ConnectionStateChanges","Throwable: " + throwable.toString()); 

        } 
      ); 
} 
public void disconnect() { 
if (subscription != null && !subscription.isUnsubscribed()) { 
subscription.unsubscribe(); 
subscription = null; 
} 
Log.d("CONNECTION2", " CON_STATUS: " + rxBleDevice.getConnectionState().toString()); 
} 

Answer 1

看起來你並不需要一個很長的寫在這裏。你的數據是否超過20字節？

無論如何，當Observable<RxBleConnection>退訂時，庫會釋放連接。如果我是你，我會怎麼做：

public void writeRxCharacteristics(String flaktCommandConcat){ 
    rxBleDevice = rxBleClient.getBleDevice(Uuids.DEVICE_ADDRESS); 

    rxBleDevice.establishConnection(true) //false 
      .flatMap(rxBleConnection -> rxBleConnection.createNewLongWriteBuilder() 
       .setCharacteristicUuid(Uuids.UUID_RX) 
       .setBytes(flaktCommandConcat.getBytes()) 
       .build() 
      ) 
      .take(1) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(
        byteArray -> { 
         Log.d("CharacteristicValue","WRITE: " + Arrays.toString(byteArray)); 
        }, 

        throwable -> { 
         Log.d("CharacteristicValue","Throwable: " + throwable.toString()); 
         rxBleActivity.onScanFailure(throwable, getContext()); 
        } 
      ); 

請確保你沒有過度使用長寫。它在1.2.0中有一個已知的bug（無關），最近在1.3.0-SNAPSHOT中被修復。