Suggested way of scanning when connecting to multiple devices about rxandroidble HOT 3 CLOSED

Observable<RxBleConnection> connectionSrc = rxBleScanResult
        .getBleDevice()
        .establishConnection(activity, false);

// 6/8/16  when found the device, stop scanning
subscribe.unsubscribe();

// TODO: 6/8/16 when un-subscribe this
Subscription conSubscription = connectionSrc
        .flatMap(new Func1<RxBleConnection, Observable<byte[]>>() {
            @Override
            public Observable<byte[]> call(final RxBleConnection rxBleConnection) {
                return rxBleConnection.readCharacteristic(BLE.BLE_CHAT_UUID);
            }
        })
        .subscribe(new Action1<byte[]>() {
            @Override
            public void call(byte[] bytes) {
                // read bytes              
                **conSubscription.unsubscribe();**
            }
        });

device.establishConnection(context, false)
    .flatMap(rxBleConnection -> rxBleConnection.readCharacteristic(characteristicUuid)
        .doOnNext(bytes -> {
            // Process read data.
        })
        .flatMap(bytes -> rxBleConnection.writeCharacteristic(characteristicUuid, bytesToWrite))
     ).subscribe(writeBytes -> {
        // Written data.
    });

Observable<RxBleConnection> connectionSrc = device.establishConnection(activity, false);             
connectionSrc
    .flatMap(rxBleConnection -> rxBleConnection.readCharacteristic(characteristicUUID))
    .subscribe(characteristicValue -> {
        // Read characteristic value.
    });
connectionSrc
    .flatMap(rxBleConnection -> rxBleConnection.writeCharacteristic(characteristicUUID, bytesToWrite))
    .subscribe(characteristicValue -> {
        // Characteristic value confirmed.
    });

CompositeSubscription compositeSubscription = new CompositeSubscription

Subscription scanSubscription = rxBleClient.scanBleDevices()
  .filter(scanResult -> /* filter the devices you're interested in */)
  .take(/* number of devices you want to scan */) // this operator will automatically unsubscribe from scanSubscription once the number of scanResults will be taken
  .map(scanResult -> scanResult.getBleDevice())
  .subscribe(bleDevice -> connectToDevice(bleDevice))
compositeSubscription.add(scanSubscription)

void connectToDevice(RxBleDevice device) {
  Subscription connectFlowSubscription = device.establishConnection(context, false)
    .flatMap(connection -> /* do what you need to do */)
    .subscribe()
  compositeSubscription.add(connectFlowSubscription)
}