Searched refs:takeWhile (Results 1 – 12 of 12) sorted by relevance
19 assertEquals(3, flow.takeWhile { true }.sum()) in <lambda>()20 assertEquals(1, flow.takeWhile { it < 2 }.single()) in <lambda>()21 assertEquals(2, flow.drop(1).takeWhile { it < 3 }.single()) in <lambda>()22 assertNull(flow.drop(1).takeWhile { it < 2 }.singleOrNull()) in <lambda>()27 assertEquals(0, emptyFlow<Int>().takeWhile { true }.sum()) in <lambda>()28 assertEquals(0, emptyFlow<Int>().takeWhile { false }.sum()) in <lambda>()45 assertEquals(1, flow.takeWhile { it < 2 }.single()) in <lambda>()59 }.takeWhile { in <lambda>()
28 val flow = integerProperty.asFlow().takeWhile { j -> j != n } in <lambda>()55 val flow = integerProperty.asFlow().takeWhile { j -> j != END_MARKER } in <lambda>()
22 …val commonPartsSize = bParts.zip(cParts).takeWhile { (basePart, childPart) -> basePart == childPar… in <lambda>()
52 .takeWhile { it > 0 } in <lambda>()
38 .takeWhile { i -> i >= 0 } // until done in <lambda>()
35 .takeWhile { i -> i >= 0 } in <lambda>()
68 .takeWhile { it != "DONE" } in <lambda>()
83 public fun <T> Flow<T>.takeWhile(predicate: suspend (T) -> Boolean): Flow<T> = flow { in <lambda>() method
47 …val indent = lines.filter(String::isNotBlank).map { it.takeWhile(Char::isWhitespace).count() }.min… in resolveSample()
1010 public fun <E> ReceiveChannel<E>.takeWhile(context: CoroutineContext = Dispatchers.Unconfined, pred… in takeWhile() method1012 for (e in this@takeWhile) { in takeWhile()
863 …(elements.takeWhile { !containsDot(it) } + elements.firstOrNull { containsDot(it) }?.firstSentence… in firstSentenceOfSummary()
732 …public static final fun takeWhile (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/…733 …public static synthetic fun takeWhile$default (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin…1041 …public static final fun takeWhile (Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function2;)…