Searched refs:enqueueReceiveInternal (Results 1 – 3 of 3) sorted by relevance
134 override fun enqueueReceiveInternal(receive: Receive<E>): Boolean = lock.withLock { in <lambda>() method135 super.enqueueReceiveInternal(receive) in <lambda>()
278 override fun enqueueReceiveInternal(receive: Receive<E>): Boolean = lock.withLock { in <lambda>() method279 super.enqueueReceiveInternal(receive) in <lambda>()
592 … protected open fun enqueueReceiveInternal(receive: Receive<E>): Boolean = if (isBufferAlwaysEmpty) in enqueueReceiveInternal() method596 … private fun enqueueReceive(receive: Receive<E>) = enqueueReceiveInternal(receive).also { result -> in result()