com.aol.cyclops.reactor.operators

Class GroupBySize<T,C extends java.util.Collection<? super T>>

java.lang.Object

com.aol.cyclops.reactor.operators.GroupBySize<T,C>

public class GroupBySize<T,C extends java.util.Collection<? super T>>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
GroupBySize(reactor.core.publisher.Flux<T> stream)
GroupBySize(reactor.core.publisher.Flux<T> stream2, java.util.function.Supplier<C> factory2)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<C>	grouped(int groupSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupBySize

public GroupBySize(reactor.core.publisher.Flux<T> stream)

GroupBySize

public GroupBySize(reactor.core.publisher.Flux<T> stream2,
                   java.util.function.Supplier<C> factory2)

Method Detail

grouped

public reactor.core.publisher.Flux<C> grouped(int groupSize)