com.aol.cyclops.reactor.comprehenders

Class FluxComprehender

java.lang.Object

com.aol.cyclops.reactor.comprehenders.FluxComprehender

All Implemented Interfaces:

com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

public class FluxComprehender
extends java.lang.Object
implements com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

Constructor Summary

Constructors

Constructor and Description
FluxComprehender()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux	empty()
reactor.core.publisher.Flux	executeflatMap(reactor.core.publisher.Flux t, java.util.function.Function fn)
java.lang.Object	filter(reactor.core.publisher.Flux t, java.util.function.Predicate p)
reactor.core.publisher.Flux	flatMap(reactor.core.publisher.Flux t, java.util.function.Function fn)
reactor.core.publisher.Flux	fromIterator(java.util.Iterator o)
java.lang.Class	getTargetClass()
boolean	instanceOfT(java.lang.Object apply)
java.lang.Object	map(reactor.core.publisher.Flux t, java.util.function.Function fn)
reactor.core.publisher.Flux	of(java.lang.Object o)
java.lang.Object	resolveForCrossTypeFlatMap(com.aol.cyclops.types.extensability.Comprehender comp, reactor.core.publisher.Flux apply)
static reactor.core.publisher.Flux	unwrapOtherMonadTypes(com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux> comp, java.lang.Object apply)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aol.cyclops.types.extensability.Comprehender

liftAndFlatMap, liftObject, priority, unwrap, unwrapOtherMonadTypes

Constructor Detail

FluxComprehender

public FluxComprehender()

Method Detail

getTargetClass

public java.lang.Class getTargetClass()

Specified by:

getTargetClass in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

filter

public java.lang.Object filter(reactor.core.publisher.Flux t,
                               java.util.function.Predicate p)

Specified by:

filter in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

map

public java.lang.Object map(reactor.core.publisher.Flux t,
                            java.util.function.Function fn)

Specified by:

map in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

executeflatMap

public reactor.core.publisher.Flux executeflatMap(reactor.core.publisher.Flux t,
                                                  java.util.function.Function fn)

Specified by:

executeflatMap in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

flatMap

public reactor.core.publisher.Flux flatMap(reactor.core.publisher.Flux t,
                                           java.util.function.Function fn)

Specified by:

flatMap in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

instanceOfT

public boolean instanceOfT(java.lang.Object apply)

Specified by:

instanceOfT in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

empty

public reactor.core.publisher.Flux empty()

Specified by:

empty in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

of

public reactor.core.publisher.Flux of(java.lang.Object o)

Specified by:

of in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

resolveForCrossTypeFlatMap

public java.lang.Object resolveForCrossTypeFlatMap(com.aol.cyclops.types.extensability.Comprehender comp,
                                                   reactor.core.publisher.Flux apply)

Specified by:

resolveForCrossTypeFlatMap in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>

unwrapOtherMonadTypes

public static reactor.core.publisher.Flux unwrapOtherMonadTypes(com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux> comp,
                                                                java.lang.Object apply)

fromIterator

public reactor.core.publisher.Flux fromIterator(java.util.Iterator o)

Specified by:

fromIterator in interface com.aol.cyclops.types.extensability.Comprehender<reactor.core.publisher.Flux>