Searched refs:AbortFlowException (Results 1 – 10 of 10) sorted by relevance
66 } catch (e: AbortFlowException) { in take()74 throw AbortFlowException(this) in emitAbort()133 throw AbortFlowException(this) in collectWhile()139 } catch (e: AbortFlowException) { in collectWhile()
16 internal expect class AbortFlowException(owner: FlowCollector<*>) : CancellationException { class20 internal fun AbortFlowException.checkOwnership(owner: FlowCollector<*>) { in checkOwnership()
111 if (collectJob.isActive) collectJob.cancel(AbortFlowException(this@unsafeFlow)) in zipImpl()132 … val otherValue = second.receiveOrNull() ?: throw AbortFlowException(this@unsafeFlow) in zipImpl()137 } catch (e: AbortFlowException) { in zipImpl()
49 else throw AbortFlowException(this) in <lambda>()51 } catch (e: AbortFlowException) { in <lambda>()
10 internal actual class AbortFlowException actual constructor( class
174 throw AbortFlowException(NopCollector) // Emulate cancellation in <lambda>()
225 assertTrue { e is AbortFlowException } in <lambda>()
86 * Fixed a problem with `AbortFlowException` in the `Flow.first` operator to avoid erroneous `NoSuch…