Jak porównać dwa strumienie w języku Java 8

Question

Jaki byłby dobry sposób porównania dwóch instancji Stream w języku Java 8 i ustalenie, czy mają one te same elementy, w szczególności w celu testowania jednostek?

Co mam teraz jest:

@Test 
void testSomething() { 
    Stream<Integer> expected; 
    Stream<Integer> thingUnderTest; 
    // (...) 
    Assert.assertArrayEquals(expected.toArray(), thingUnderTest.toArray()); 
} 

lub alternatywnie:

Assert.assertEquals(
    expected.collect(Collectors.toList()), 
    thingUnderTest.collect(Collectors.toList())); 

Ale to oznacza, że ​​jestem konstruowania dwa zbiory i ich wyrzuceniem. Nie jest to problem z wydajnością, biorąc pod uwagę rozmiar moich strumieni testowych, ale zastanawiam się, czy istnieje kanoniczny sposób porównania dwóch strumieni.

Answer 1

static void assertStreamEquals(Stream<?> s1, Stream<?> s2) 
{ 
    Iterator<?> iter1 = s1.iterator(), iter2 = s2.iterator(); 
    while(iter1.hasNext() && iter2.hasNext()) 
     assertEquals(iter1.next(), iter2.next()); 
    assert !iter1.hasNext() && !iter2.hasNext(); 
} 

Answer 2

Zbieranie strumienia w trakcie testu (jak pokazano) jest prostym i skutecznym sposobem wykonania testu. Możesz utworzyć listę oczekiwanych wyników w najprostszy dostępny sposób, który może nie gromadzić strumienia.

Alternatywnie, w przypadku większości bibliotek do tworzenia próbnych współpracowników, można kpić z Consumer, który "oczekuje" serii wywołań accept() z poszczególnymi elementami. Consume the Stream z nim, a następnie "sprawdź", czy spełnione są skonfigurowane oczekiwania.

Answer 3

public static boolean equalStreams(Stream<?>...streams) { 
    List<Iterator<?>>is = Arrays.stream(streams).map(Stream::iterator).collect(Collectors.toList()); 
    while(is.stream().allMatch(Iterator::hasNext)) 
     if(is.stream().map(Iterator::next).distinct().limit(2).count()>1) return false; 
    return is.stream().noneMatch(Iterator::hasNext); 
}