Searched defs:streamB (Results 1 – 4 of 4) sorted by relevance
151 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated() local162 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_stream_concat() local174 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_stream_flatMap() local496 Stream<Integer> streamB = IntStream.range(0, 100000).mapToObj(i -> i).parallel(); in testForEachPair_parallel() local
347 Stream<A> streamA, Stream<B> streamB, BiFunction<? super A, ? super B, R> function) { in zip()
39 SkDynamicMemoryWStream streamA, streamB; in textBlobsAllPathsEqual() local
520 BaseDecodeParam streamB; member1701 DecodeTestParam streamB{interleavingTest.type, interleavingTest.streamB}; in createVideoDecodeTests() local