Searched refs:tryResumeReceive (Results 1 – 4 of 4) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | AbstractChannel.kt | 53 val token = receive.tryResumeReceive(element, null) in <lambda>()
363 val token = affected.tryResumeReceive(element, prepareOp) ?: return REMOVE_PREPARED in <lambda>()
891 override fun tryResumeReceive(value: E, otherOp: PrepareOp?): Symbol? { in tryResumeReceive() method in ReceiveElement
924 override fun tryResumeReceive(value: E, otherOp: PrepareOp?): Symbol? { in tryResumeReceive() method in ReceiveHasNext
966 override fun tryResumeReceive(value: E, otherOp: PrepareOp?): Symbol? = in resumeOnCancellationFun() method in ReceiveSelect
1058 fun tryResumeReceive(value: E, otherOp: PrepareOp?): Symbol? in tryResumeReceive() method
1112 …override fun tryResumeReceive(value: E, otherOp: PrepareOp?): Symbol? = RESUME_TOKEN.also { otherO… in <lambda>() method in Closed
|
| D | ConflatedChannel.kt | 45 val token = receive!!.tryResumeReceive(element, null) in offerInternal()
|
| D | ArrayBroadcastChannel.kt | 259 val token = receive.tryResumeReceive(result as E, null) ?: continue in elementAt()
|
| D | ArrayChannel.kt | 72 val token = receive!!.tryResumeReceive(element, null) in offerInternal()
|