Commit 55a66ac

committed

Improve ReceiveChannel operators implementations to guarantee closing

of the source channels under all circumstances; `onCompletion` added to `produce` builder; `ReceiveChannel.consumes(): CompletionHandler` extension fun. Fixes #279

1 parent fcdce10 commit 55a66acCopy full SHA for 55a66ac

3 files changed

+1188

-225

lines changed

core/kotlinx-coroutines-core/src
- main/kotlin/kotlinx/coroutines/experimental/channels
  - Channels.kt
  - Produce.kt
- test/kotlin/kotlinx/coroutines/experimental/channels
  - ChannelsConsumeTest.kt

3 files changed

+1188

-225

lines changed

Comments

(0)

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Commit 55a66ac

3 files changed

3 files changed

File tree

3 files changed

3 files changed

0 commit comments