Searched refs:pollResult (Results 1 – 3 of 3) sorted by relevance
444 …override val pollResult: E, // E | Closed - the result pollInternal returns when it rendezvous wit… in <lambda>() constant in SendSelect468 … channel.onUndeliveredElement?.callUndeliveredElement(pollResult, select.completion.context) in <lambda>()471 override fun toString(): String = "SendSelect@$hexAddress($pollResult)[$channel, $select]" in <lambda>()477 override val pollResult: Any? get() = element in <lambda>() constant in SendBuffered520 return send.pollResult in pollInternal()539 return pollOp.result.pollResult in pollSelectInternal()738 val pollResult = pollSelectInternal(select) in registerSelectReceiveMode() constant740 pollResult === ALREADY_SELECTED -> return in registerSelectReceiveMode()741 pollResult === POLL_FAILED -> {} // retry in registerSelectReceiveMode()742 pollResult === RETRY_ATOMIC -> {} // retry in registerSelectReceiveMode()[all …]
198 replacement = send!!.pollResult in pollInternal()239 replacement = send!!.pollResult in pollSelectInternal()
178 buffer[(tail % capacity).toInt()] = (send as Send).pollResult in updateHead()