org.openimaj.util.stream.combine

Class StreamCombiner<A,B>

java.lang.Object

org.openimaj.util.stream.AbstractStream<IndependentPair<A,B>>

org.openimaj.util.stream.combine.StreamCombiner<A,B>

Type Parameters:

A - Type of payload in first stream

B - Type of payload in second stream

All Implemented Interfaces:

Iterable<IndependentPair<A,B>>, Iterator<IndependentPair<A,B>>, Stream<IndependentPair<A,B>>

public class StreamCombiner<A,B>
extends AbstractStream<IndependentPair<A,B>>

A stream combiner takes two streams and produces a new stream of synchronised pairs of the stream values. The two streams are consumed in two threads which the next() method waits to complete before returning

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
StreamCombiner(Stream<A> a, Stream<B> b)

Method Summary

Modifier and Type	Method and Description
static <A,B> StreamCombiner<A,B>	combine(Stream<A> a, Stream<B> b) Create a new StreamCombiner from the given streams
boolean	hasNext()
IndependentPair<A,B>	next()

Methods inherited from class org.openimaj.util.stream.AbstractStream

filter, forEach, forEach, forEach, iterator, map, map, parallelForEach, parallelForEach, remove, transform

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

StreamCombiner

public StreamCombiner(Stream<A> a,
                      Stream<B> b)

Parameters:

a -

b -

Method Detail

hasNext

public boolean hasNext()

next

public IndependentPair<A,B> next()

combine

public static <A,B> StreamCombiner<A,B> combine(Stream<A> a,
                                                Stream<B> b)

Create a new StreamCombiner from the given streams

Parameters:

a - first stream

b - second stream

Returns:

the combined stream