org.openimaj.util.stream.window

Class MetaPayloadStreamCombiner<AP,AM,BP,BM>

java.lang.Object

org.openimaj.util.stream.AbstractStream<MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>>

org.openimaj.util.stream.window.MetaPayloadStreamCombiner<AP,AM,BP,BM>

Type Parameters:

AP -

AM -

BP -

BM -

All Implemented Interfaces:

Iterable<MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>>, Iterator<MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>>, Stream<MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>>

public class MetaPayloadStreamCombiner<AP,AM,BP,BM>
extends AbstractStream<MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>>

A stream combiner takes two streams and produces a new stream of syncrhonised 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
MetaPayloadStreamCombiner(Stream<A> a, Stream<? extends MetaPayload<BP,BM>> b)

Method Summary

Methods

Modifier and Type	Method and Description
static <AP,AM,BP,BM> MetaPayloadStreamCombiner<AP,AM,BP,BM>	combine(Stream<? extends MetaPayload<AP,AM>> a, Stream<? extends MetaPayload<BP,BM>> b)
boolean	hasNext()
MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>>	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

Constructor Detail

MetaPayloadStreamCombiner

public MetaPayloadStreamCombiner(Stream<A> a,
                         Stream<? extends MetaPayload<BP,BM>> b)

Parameters:

a -

b -

Method Detail

hasNext

public boolean hasNext()

next

public MetaPayload<IndependentPair<AP,BP>,IndependentPair<AM,BM>> next()

combine

public static <AP,AM,BP,BM> MetaPayloadStreamCombiner<AP,AM,BP,BM> combine(Stream<? extends MetaPayload<AP,AM>> a,
                                                           Stream<? extends MetaPayload<BP,BM>> b)

Parameters:

a -

b -

Returns:

an aggregation of the two streams