com.aol.cyclops2.util.stream.pushable

Class PushableFutureStream<T>

java.lang.Object

org.jooq.lambda.tuple.Tuple2<X,R>

com.aol.cyclops2.util.stream.pushable.AbstractPushableStream<T,Queue<T>,FutureStream<T>>

com.aol.cyclops2.util.stream.pushable.PushableFutureStream<T>

Type Parameters:

T - data type

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Comparable<org.jooq.lambda.tuple.Tuple2<Queue<T>,FutureStream<T>>>, java.lang.Iterable<java.lang.Object>, org.jooq.lambda.tuple.Tuple

public class PushableFutureStream<T>
extends AbstractPushableStream<T,Queue<T>,FutureStream<T>>

A more concrete Tuple2 impl v1 is Queue<T> v2 is LazyFutureStream<T>

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jooq.lambda.tuple.Tuple2

v1, v2

Constructor Summary

Constructors

Constructor and Description
PushableFutureStream(Queue<T> v1, FutureStream<T> v2)

Method Summary

Methods inherited from class com.aol.cyclops2.util.stream.pushable.AbstractPushableStream

getInput, getStream, peekInput, peekStream, visit

Methods inherited from class org.jooq.lambda.tuple.Tuple2

array, clone, compareTo, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, concat, degree, equals, hashCode, intersect, iterator, limit0, limit1, limit2, list, map, map1, map2, overlaps, skip0, skip1, skip2, split0, split1, split2, swap, toArray, toList, toMap, toMap, toMap, toMap, toSeq, toString, v1, v2

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jooq.lambda.tuple.Tuple

collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, collectors, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, consumer, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, function, range, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple, tuple

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

PushableFutureStream

public PushableFutureStream(Queue<T> v1,
                            FutureStream<T> v2)