pakoito
06/17/2019, 9:12 AMscanner.startScanning()
.flatMap { item ->
IO { Timber.d("Scanned item: $item") }.map { item }
}.flatMap {
scanner.setStatusText(it.data)
}
.handleErrorWith { err ->
IO { Timber.e(err) }
}.unsafeRunAsync { }
which means you can convert to fx
IO.fx {
val (item) = scanner.startScanning()
Timber.d("Scanned item: $item")
!scanner.setStatusText(item.data)
}.handleErrorWith { err ->
IO { Timber.e(err) }
}.unsafeRunAsync { }