com.aol.cyclops.reactor.operators

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

java.lang.Object

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<C>	batchWhile(java.util.function.Predicate<? super T> predicate)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupedWhile

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

GroupedWhile

public GroupedWhile(reactor.core.publisher.Flux<T> stream,
                    java.util.function.Supplier<C> factory)

Method Detail

batchWhile

public reactor.core.publisher.Flux<C> batchWhile(java.util.function.Predicate<? super T> predicate)