Searched refs:outputFlow (Results 1 – 1 of 1) sorted by relevance
38 val outputFlow = inputFlow.mapItem { it.length } regex40 assertThat(outputFlow.first()).containsExactly(1, 2, 3).inOrder()47 val outputFlow = inputFlow.asyncMapItem { it.length } regex49 assertThat(outputFlow.first()).containsExactly(1, 2, 3).inOrder()56 val outputFlow = inputFlow.filterItem { it.length >= 2 } regex66 val outputFlow = mainFlow.waitFirst(otherFlow) regex68 assertThat(outputFlow.count()).isEqualTo(0)76 val outputFlow = mainFlow.waitFirst(otherFlow) regex78 assertThat(outputFlow.toList()).containsExactly("A")86 val outputFlow = mainFlow.waitFirst(otherFlow) regex[all …]