com.aol.cyclops.reactor.collections.extensions.base

Class AbstractFluentCollectionX.PersistentLazyCollection<T,C extends java.util.Collection<T>>

java.lang.Object

com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.PersistentLazyCollection<T,C>

All Implemented Interfaces:

LazyFluentCollection<T,C>

Enclosing class:

AbstractFluentCollectionX<T>

public static class AbstractFluentCollectionX.PersistentLazyCollection<T,C extends java.util.Collection<T>>
extends java.lang.Object
implements LazyFluentCollection<T,C>

Constructor Summary

Constructors

Constructor and Description
PersistentLazyCollection(C list, reactor.core.publisher.Flux<T> seq, Reducer<C> reducer)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<T>	flux()
C	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentLazyCollection

public PersistentLazyCollection(C list,
                                reactor.core.publisher.Flux<T> seq,
                                Reducer<C> reducer)

Method Detail

get

public C get()

Specified by:

get in interface LazyFluentCollection<T,C extends java.util.Collection<T>>

Returns:

Wrapped Collection

flux

public reactor.core.publisher.Flux<T> flux()

Specified by:

flux in interface LazyFluentCollection<T,C extends java.util.Collection<T>>

Returns:

Collection data inside a stream - a Reactor Flux