com.aol.cyclops.streams.operators

Class BatchByTimeAndSizeOperator<T,C extends java.util.Collection<T>>

java.lang.Object

com.aol.cyclops.streams.operators.BatchByTimeAndSizeOperator<T,C>

public class BatchByTimeAndSizeOperator<T,C extends java.util.Collection<T>>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
BatchByTimeAndSizeOperator(java.util.stream.Stream<T> stream)
BatchByTimeAndSizeOperator(java.util.stream.Stream<T> stream2, java.util.function.Supplier<C> factory2)

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<C>	batchBySizeAndTime(int size, long time, java.util.concurrent.TimeUnit t)

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchByTimeAndSizeOperator

public BatchByTimeAndSizeOperator(java.util.stream.Stream<T> stream)

BatchByTimeAndSizeOperator

public BatchByTimeAndSizeOperator(java.util.stream.Stream<T> stream2,
                                  java.util.function.Supplier<C> factory2)

Method Detail

batchBySizeAndTime

public java.util.stream.Stream<C> batchBySizeAndTime(int size,
                                                     long time,
                                                     java.util.concurrent.TimeUnit t)