Searched refs:checkOwnership (Results 1 – 4 of 4) sorted by relevance
67 e.checkOwnership(owner = this) in take()138 e.checkOwnership(collector) in collectWhile()
20 internal fun AbortFlowException.checkOwnership(owner: FlowCollector<*>) { in checkOwnership() method
137 e.checkOwnership(owner = this@unsafeFlow) in zipImpl()
52 e.checkOwnership(owner = this) in <lambda>()