Home
last modified time | relevance | path

Searched defs:trySend (Results 1 – 9 of 9) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/lincheck/
DChannelsLincheckTest.kt72 override fun trySend(value: Int) = super.trySend(value) in <lambda>() method
111 open fun trySend(@Param(name = "value") value: Int): Any = c.trySend(value) in trySend() method in ChannelLincheckTestBase
192 fun trySend(element: Int): Any { in trySend() method in SequentialIntChannelBase
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/
DActor.kt176 override fun trySend(element: E): ChannelResult<Unit> { in trySend() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DConflatedBufferedChannel.kt57 override fun trySend(element: E): ChannelResult<Unit> = trySendImpl(element, isSendOp = false) in <lambda>() method
DChannel.kt81 public fun trySend(element: E): ChannelResult<Unit> in send() method
DBroadcastChannel.kt237 override fun trySend(element: E): ChannelResult<Unit> = lock.withLock { // protected by lock in <lambda>() method in kotlinx.coroutines.channels.BroadcastChannelImpl
DBufferedChannel.kt186 override fun trySend(element: E): ChannelResult<Unit> { in <lambda>() method in kotlinx.coroutines.channels.BufferedChannel
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxObservable.kt106 override fun trySend(element: T): ChannelResult<Unit> = in trySend() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxObservable.kt106 override fun trySend(element: T): ChannelResult<Unit> = in trySend() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DPublish.kt120 override fun trySend(element: T): ChannelResult<Unit> = in trySend() method