| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | AbstractChannel.kt | 67 protected open fun offerSelectInternal(element: E, select: SelectInstance<*>): Any { in <lambda>()
372 …override fun <R> registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendCh… in <lambda>()
377 …private fun <R> registerSelectSend(select: SelectInstance<R>, element: E, block: suspend (SendChan… in <lambda>()
446 @JvmField val select: SelectInstance<R>, in <lambda>()
532 protected open fun pollSelectInternal(select: SelectInstance<*>): Any? { in pollSelectInternal()
711 … override fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (E) -> R) { in registerSelectClause1()
719 … override fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (E?) -> R) { in registerSelectClause1()
727 …override fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (ValueOrClosed<E>… in registerSelectClause1()
732 …private fun <R> registerSelectReceiveMode(select: SelectInstance<R>, receiveMode: Int, block: susp… in registerSelectReceiveMode()
749 …private fun <R> (suspend (Any?) -> R).tryStartBlockUnintercepted(select: SelectInstance<R>, receiv… in tryStartBlockUnintercepted()
[all …]
|
| D | ConflatedChannel.kt | 61 protected override fun offerSelectInternal(element: E, select: SelectInstance<*>): Any { in offerSelectInternal()
105 protected override fun pollSelectInternal(select: SelectInstance<*>): Any? { in pollSelectInternal()
|
| D | LinkedListChannel.kt | 46 protected override fun offerSelectInternal(element: E, select: SelectInstance<*>): Any { in offerSelectInternal()
|
| D | ConflatedBroadcastChannel.kt | 269 …override fun <R> registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendCh… in <lambda>()
274 …private fun <R> registerSelectSend(select: SelectInstance<R>, element: E, block: suspend (SendChan… in <lambda>()
|
| D | ArrayBroadcastChannel.kt | 110 override fun offerSelectInternal(element: E, select: SelectInstance<*>): Any { in offerSelectInternal()
304 override fun pollSelectInternal(select: SelectInstance<*>): Any? { in elementAt()
|
| D | ArrayChannel.kt | 89 protected override fun offerSelectInternal(element: E, select: SelectInstance<*>): Any { in offerSelectInternal()
218 protected override fun pollSelectInternal(select: SelectInstance<*>): Any? { in pollSelectInternal()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/ |
| D | Select.kt | 78 public fun <R> registerSelectClause0(select: SelectInstance<R>, block: suspend () -> R) in onTimeout()
90 public fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (Q) -> R) in registerSelectClause1()
102 … public fun <R> registerSelectClause2(select: SelectInstance<R>, param: P, block: suspend (Q) -> R) in registerSelectClause1()
112 public interface SelectInstance<in R> { interface
238 SelectInstance<R>, Continuation<R>, CoroutineStackFrame in next()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CompletableDeferred.kt | 88 override fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (T) -> R) =
|
| D | JobSupport.kt | 563 …public final override fun <R> registerSelectClause0(select: SelectInstance<R>, block: suspend () -… in <lambda>()
1239 …internal fun <T, R> registerSelectClause1Internal(select: SelectInstance<R>, block: suspend (T) ->… in <lambda>()
1267 internal fun <T, R> selectAwaitCompletion(select: SelectInstance<R>, block: suspend (T) -> R) { in <lambda>()
1427 private val select: SelectInstance<R>, in invoke()
1439 private val select: SelectInstance<R>,
|
| D | Builders.common.kt | 103 override fun <R> registerSelectClause1(select: SelectInstance<R>, block: suspend (T) -> R) = in getCompleted()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Mutex.kt | 229 …override fun <R> registerSelectClause2(select: SelectInstance<R>, owner: Any?, block: suspend (Mut… in toString()
373 @JvmField val select: SelectInstance<R>, in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 179 …override fun <R> registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendCh… in registerSelectClause2()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxObservable.kt | 97 …override fun <R> registerSelectClause2(select: SelectInstance<R>, element: T, block: suspend (Send… in registerSelectClause2()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxObservable.kt | 111 …override fun <R> registerSelectClause2(select: SelectInstance<R>, element: T, block: suspend (Send… in registerSelectClause2()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Publish.kt | 122 …override fun <R> registerSelectClause2(select: SelectInstance<R>, element: T, block: suspend (Send… in registerSelectClause2()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| D | kotlinx-coroutines-reactive.api | 63 …public fun registerSelectClause2 (Lkotlinx/coroutines/selects/SelectInstance;Ljava/lang/Object;Lko…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 437 …public final fun registerSelectClause0 (Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/fun…
1194 …neStackFrame, kotlinx/coroutines/selects/SelectBuilder, kotlinx/coroutines/selects/SelectInstance {
1218 …public abstract fun registerSelectClause0 (Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/…
1222 …public abstract fun registerSelectClause1 (Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/…
1226 …public abstract fun registerSelectClause2 (Lkotlinx/coroutines/selects/SelectInstance;Ljava/lang/O…
1229 public abstract interface class kotlinx/coroutines/selects/SelectInstance {
|