`map` would be 1000x more approachable if written ...
# rx
j
map
would be 1000x more approachable if written like
Copy code
suspend override fun subscribe() = produce(Unconfined) {
    for (value in upstream.subscribe()) {
      send(mapper(value))
    }
  }