| /* |
| * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. |
| */ |
| |
| package kotlinx.coroutines.flow.internal |
| |
| import kotlinx.coroutines.* |
| import kotlinx.coroutines.channels.* |
| import kotlinx.coroutines.flow.* |
| |
| /** |
| * Collection that sends to channel |
| * @suppress **This an internal API and should not be used from general code.** |
| */ |
| @InternalCoroutinesApi |
| public class SendingCollector<T>( |
| private val channel: SendChannel<T> |
| ) : FlowCollector<T> { |
| override suspend fun emit(value: T): Unit = channel.send(value) |
| } |