RxBleClient mulit connections about rxandroidble HOT 4 CLOSED

val cache = HashMap<RxBleDevice, Observable<RxBleConnection>>()

fun getConnection(device: RxBleDevice): Observable<RxBleConnection> {
    if (cache.contains(device)) return cache.get(device)
    val connection = device.establishConnection(false).compose(ReplayingShare.instance())
        .doOnError {
            //clean cache/etc
            cache.remove(device)
        }
    cache.put(device, connection)
    return connection
}

fun startVoiceService(device: RxBleDevice) {
    val disposable1 = getConnection(device).flatMap { connection ->
        //notification
        connection.setupNotification(UUID.randomUUID()).flatMap { observables ->
            //request like get voice codec etc
            connection.writeCharacteristic(
                UUID.randomUUID(),
                byteArrayOf()
            ).flatMapObservable {
                Observable.just(observables)
            }
        }.flatMap { it }
            .flatMap {
                //some logic
                if (it[0] == 0x0.toByte()) {
                    Observable.just(1)
                } else Observable.just(2)

            }

    }
}

fun startUpdateCheck(device: RxBleDevice) {
    val disposable2 = getConnection(device).flatMapSingle { connection ->
        //get sw version ect
        connection.readCharacteristic(UUID.fromString("00002a28-0000-1000-8000-00805f9b34fb"))
            .flatMap {
                if (it.littleEndianConversion() > 80) {
                    //logic to find update
                    Single.just(1)
                } else {
                    Single.just(2)
                }
            }
    }
}