uli
06/18/2018, 1:34 PMconsumeEach will execute code after the consumeEach. Is this expected behaviour?
In the below example, if job.cancel() is called, while the job is waiting for new Items from receiveChannel it will print out Done
job = launch(coroutineContext) {
                receiveChannel.consumeEach { r ->
                    output.send(r)
                }
                println("Done")
                output.close()
            }
If relevant, I do have a self contained sample, which is an alternative implementation of @hannesstruss switchMap example.
Please let me know if I should post it.Vsevolod Tolstopyatov [JB]
06/18/2018, 3:54 PMconsumeEach re-throws exceptions.
Issue is somewhere in switchMap implementation (I haven’t looked at it yet)