Searched refs:collectJob (Results 1 – 2 of 2) sorted by relevance
33 val collectJob = collectElement as Job? in checkContext() constant34 val emissionParentJob = (element as Job).transitiveCoroutineParent(collectJob) in checkContext()66 if (emissionParentJob !== collectJob) { in checkContext()70 "\t\tChild of $emissionParentJob, expected child of $collectJob.\n" + in checkContext()81 if (collectJob == null) count else count + 1 in checkContext()93 internal tailrec fun Job?.transitiveCoroutineParent(collectJob: Job?): Job? { in transitiveCoroutineParent()95 if (this === collectJob) return this in transitiveCoroutineParent()97 return parent.transitiveCoroutineParent(collectJob) in transitiveCoroutineParent()
105 val collectJob = Job() in zipImpl() constant108 if (collectJob.isActive) collectJob.cancel(AbortFlowException(this@unsafeFlow)) in zipImpl()126 withContextUndispatched(coroutineContext + collectJob, Unit) { in zipImpl()