Cristian MG
06/12/2023, 8:28 AMtravis
06/12/2023, 8:51 AMCristian MG
06/12/2023, 8:56 AMCristian MG
06/12/2023, 8:57 AMCristian MG
06/12/2023, 9:01 AMtravis
06/12/2023, 9:20 AMCristian MG
06/12/2023, 9:29 AMCristian MG
06/12/2023, 9:30 AMCristian MG
06/12/2023, 9:30 AMtravis
06/12/2023, 9:30 AMCristian MG
06/12/2023, 9:31 AMtravis
06/12/2023, 9:31 AMCristian MG
06/12/2023, 9:32 AMCristian MG
06/12/2023, 9:32 AMCristian MG
06/12/2023, 9:34 AMtravis
06/12/2023, 9:34 AMCristian MG
06/12/2023, 9:36 AMtravis
06/12/2023, 9:37 AMcollect
on the observe
.Cristian MG
06/12/2023, 9:38 AMfun treadmillData(
connection: DeviceConnection
): Flow<TreadmillData> =
connection.getConnection().observe(
characteristicOf(
FitFlowServices.FitnessMachine.uuid,
FtmsCharacteristic.TreadmillData.uuid
)
).map {
TreadmillDataFlags.byteToModel(it)
}.runningReduce { accumulator, value ->
accumulator + value
}.map {
TreadmillData(it)
}
Cristian MG
06/12/2023, 9:38 AMtravis
06/12/2023, 9:40 AMonEach
after the observe
(and before the first map
) to confirm you are not getting emissions?travis
06/12/2023, 9:46 AMCristian MG
06/12/2023, 9:56 AMtravis
06/12/2023, 10:41 PMtravis
06/13/2023, 2:09 AMCristian MG
06/13/2023, 7:31 AMtravis
06/13/2023, 7:31 AMtravis
06/13/2023, 7:31 AMCristian MG
06/13/2023, 7:32 AM