Zwei Ströme zusammenführen

Question

Ich versuche, eine Methode zu implementieren, um die Werte in zwei Stream s basierend auf einem Comparator für die Werte zusammenzuführen.

Ich hatte eine Möglichkeit, dies zu tun, wo ich über die Streams iterieren und die Werte in eine Stream.Builder einfügen, aber ich konnte nicht herausfinden, wie eine Lazy-ausgewertete Version (wie viele Stream-Operationen sind)), so kann es auch mit unendlichen Strömen umgehen.

Alles, was ich will es einen Einzel verschmelzenden Pass auf den Eingangsdaten tun durchführen, nicht sortiert die Ströme (in der Tat ist es wahrscheinlich, dass die Ströme ungeordnet sein werden, diese Störung muss erhalten bleiben) .

static Stream<E> merge(Stream<E> first, Stream<E> second, Comparator<E> c) 

Wie kann ich zwei Ströme so zusammenführen?

void merge(Queue<E> first, Queue<E> second, Consumer<E> out, Comparator<E> c){ 
    while(!first.isEmpty() && !second.isEmpty() 
     if(c.compare(first.peek(), second.peek()) <= 0) 
      out.accept(first.remove()); 
     else 
      out.accept(second.remove()); 
    for(E e:first) 
     out.accept(e); 
    for(E e:second) 
     out.accept(e); 
} 

Aber ich brauche diese mit lazy evaluation zu tun, und Bächen:

Wenn ich mit zwei Queue s als Eingang und einig Consumer als Ausgang tat dies, wäre es ziemlich einfach sein.

die Kommentare zu adressieren, sind hier einige Beispiel-Eingänge und das Ergebnis:

Beispiel 1:

merge(
    Stream.of(1, 2, 3, 1, 2, 3), 
    Stream.of(2, 2, 3, 2, 2, 2), 
    Comparator.naturalOrder() 
); 

würde einen Stream zurück, die diese Sequenz erzeugen würde:

1, 2, 2, 2, 3, 3, 1, 2, 2, 2, 2, 3 

Beispiel 2:

merge(
    Stream.iterate(5, i->i-1), 
    Stream.iterate(1, i->i+1), 
    Comparator.naturalOrder() 
); 

würde eine unendliche (na ja, ein INT_MAX + 5 Artikel) Strom zurück, die die Sequenz erzeugen würde:

1, 2, 3, 4, 5, 5, 4, 3, 2, 1, 0, -1 ... 

Wie Sie sehen können, ist dies nicht nur ist concat(first,second).sort(), da (a) Sie können nicht sortieren unendliche Ströme, und (b) selbst wenn Sie die Ströme sortieren können, gibt es nicht das gewünschte Ergebnis.

Answer 1

Sie müssen Spliterator implementieren, anstatt Stream.Builder zu durchlaufen. Dazu können Sie sogar einfach eine Iterator durchlaufen, da es eine ziemlich sequenzielle Operation ist. Mit Guava leicht,

return StreamSupport.stream(Spliterators.spliteratorUnknownSize(
    Iterators.mergeSorted(
     Arrays.asList(stream1.iterator(), stream2.iterator()), 
     comparator), 
    Spliterator.ORDERED), 
    false /* not parallel */);