I need to make an Observable with n number of items in it, but I don't know how to achieve this. He...

# announcements

[Shawn Karber_]

I need to make an Observable with n number of items in it, but I don't know how to achieve this.

Here's the code I'm using as an example:

device.establishConnection(false)
    .flatMap(rxBleConnection -> Observable.combineLatest(
        rxBleConnection.readCharacteristic(firstUUID),
        rxBleConnection.readCharacteristic(secondUUID),
        YourModelCombiningTwoValues::new
    ))
    .subscribe(model -> {
        // Process your model.
    });

Here's the code I am trying to write:

device.establishConnection(true)
    .flatMap { rxBleConnection ->
        val characteristicReads: MutableList<Single<ByteArray>> =
            mutableListOf()
        for (c in characteristics) {
            characteristicReads.add(rxBleConnection.readCharacteristic(c.uuid))
        }
        Observable.combineLatest(*characteristicReads)
    }
    .subscribe({ onConnectionSuccess(it) }, { onConnectionFailure(it) })

The error is:

Type mismatch.
   Required: ObservableSource<out TypeVariable(R)!>!
   Found: Unit

[Vasile Glijin]

Check the signature on Observable.combineLatest(*characteristicReads)

[araqnid]

don’t you need *(characteristicReads.toTypedArray()) ?

[araqnid]

(or use a different method signature that takes a collection rather than a vararg)