org.openimaj.util.stream.combine

Class RoundRobinStreamCombiner<T>

java.lang.Object

org.openimaj.util.stream.AbstractStream<T>

org.openimaj.util.stream.combine.RoundRobinStreamCombiner<T>

Type Parameters:

T - Type of items in the streams being combined

All Implemented Interfaces:

Iterable<T>, Iterator<T>, Stream<T>

public class RoundRobinStreamCombiner<T>
extends AbstractStream<T>

Given a List of streams of a given type, present a stream of that type which asks each stream in the List for an item in turn. If any stream in the List says it has no item, this Stream will report it has no item and likely stop processing all streams. The specifics of this behaviour are that if when it comes to a stream's turn to provide an item it fails to do so, all the streams will stop being asked simultaneously.

Author:

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

Constructor Summary

Constructors

Constructor and Description
RoundRobinStreamCombiner(List<Stream<T>> streams) Construct with the given streams.

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
T	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

RoundRobinStreamCombiner

public RoundRobinStreamCombiner(List<Stream<T>> streams)

Construct with the given streams. Items from each stream will be consumed in a round-robin fashion, starting with the first stream given.

Parameters:

streams - the streams to consume

Method Detail

hasNext

public boolean hasNext()

next

public T next()