T - the type of elements held in the nested Fluxespublic class FluxTValue<T> extends java.lang.Object implements FluxT<T>
| Modifier and Type | Method and Description |
|---|---|
<R> FluxTValue<R> |
empty() |
boolean |
equals(java.lang.Object o) |
FluxTValue<T> |
filter(java.util.function.Predicate<? super T> test)
Filter the wrapped Flux
|
<B> FluxTValue<B> |
flatMap(java.util.function.Function<? super T,? extends reactor.core.publisher.Flux<? extends B>> f)
Perform a flatMap operation on each nested Flux
|
<B> FluxTValue<B> |
flatMapT(java.util.function.Function<? super T,FluxTValue<? extends B>> f)
Flat Map the wrapped Flux
|
reactor.core.publisher.Flux<T> |
flux() |
static <A> FluxTValue<A> |
fromAnyM(AnyMValue<A> anyM)
|
reactor.core.publisher.Flux<T> |
get() |
int |
hashCode() |
boolean |
isSeqPresent() |
boolean |
isStreamPresent() |
java.util.Iterator<T> |
iterator() |
static <U,R> java.util.function.Function<FluxTValue<U>,FluxTValue<R>> |
lift(java.util.function.Function<? super U,? extends R> fn)
Lift a function into one that accepts and returns an FluxT
This allows multiple monad types to add functionality to existing functions and methods
e.g.
|
<B> FluxTValue<B> |
map(java.util.function.Function<? super T,? extends B> f)
Map the wrapped Flux
|
AnyM<? extends CyclopsCollectable<T>> |
nestedCollectables() |
AnyM<? extends IterableFoldable<T>> |
nestedFoldables() |
static <A> FluxTValue<A> |
of(AnyMValue<? extends reactor.core.publisher.Flux<A>> monads)
Create a FluxT from an AnyM that wraps a monad containing a Stream
|
FluxTValue<T> |
peek(java.util.function.Consumer<? super T> peek)
Peek at the current value of the Flux
|
ReactiveSeq<T> |
stream() |
java.lang.String |
toString() |
AnyM<? extends Traversable<T>> |
transformerStream() |
<T> FluxTValue<T> |
unit(T unit)
Create an instance of the same FluxTransformer that contains a Flux with just the value provided
|
<T> FluxTValue<T> |
unitAnyM(AnyM<Traversable<T>> traversable) |
<U> FluxTValue<U> |
unitIterator(java.util.Iterator<U> u)
Create an instance of the same FluxTransformer type from the provided Iterator over raw values.
|
AnyMValue<reactor.core.publisher.Flux<T>> |
unwrap() |
clone, finalize, getClass, notify, notifyAll, wait, wait, waitbind, cast, combine, cycle, cycle, cycleUntil, cycleWhile, distinct, dropRight, dropUntil, dropWhile, emptyFlux, emptyOptional, filterNot, fluxOfFlux, fromAnyM, fromAnyMSeq, fromAnyMValue, fromFuture, fromIterable, fromIterableValue, fromMono, fromOptional, fromPublisher, fromValue, grouped, grouped, grouped, grouped, groupedStatefullyUntil, groupedUntil, groupedUntil, groupedWhile, groupedWhile, intersperse, limit, limitLast, limitUntil, limitWhile, notNull, of, ofType, onEmpty, onEmptyGet, onEmptyThrow, patternMatch, reverse, scanLeft, scanLeft, scanRight, scanRight, shuffle, shuffle, skip, skipLast, skipUntil, skipWhile, slice, sliding, sliding, sorted, sorted, sorted, takeRight, takeUntil, takeWhile, trampoline, zip, zip, zip, zip, zip, zip, zip3, zip4, zipWithIndexfutureOperations, lazyOperations, subscribeseq, toCompletableFuture, toDequeX, toEvalAlways, toEvalLater, toEvalNow, toFutureStream, toFutureStream, toFutureW, toIor, toIorSecondary, toListX, toMapX, toMaybe, toOptional, toPBagX, toPMapX, toPOrderedSetX, toPQueueX, toPSetX, toPStackX, toPVectorX, toQueueX, toSetX, toSimpleReact, toSimpleReact, toSortedSetX, toStreamable, toTry, toValue, toValueMap, toValueSet, toXor, toXorSecondarydrop, take, traversablefixedDelay, onePer, xPerfutureStream, getStreamable, isEmpty, jdkStream, reactiveSeq, reveresedJDKStream, reveresedStreamendsWith, endsWithIterable, findFirst, firstValue, foldRight, foldRight, foldRight, foldRightMapToType, get, groupBy, headAndTail, join, join, join, mapReduce, mapReduce, print, print, printErr, printOut, reduce, reduce, reduce, reduce, reduce, reduce, schedule, scheduleFixedDelay, scheduleFixedRate, single, single, singleOptional, startsWith, startsWithIterable, toConcurrentLazyCollection, toConcurrentLazyStreamable, toLazyCollection, validate, visitallMatch, anyMatch, collect, collect, listT, noneMatch, setT, streamableT, streamT, toListOfLists, toNestedListX, toNestedSetX, toSetOfSetspublic boolean isSeqPresent()
isSeqPresent in interface TransformerSeq<T>public FluxTValue<T> peek(java.util.function.Consumer<? super T> peek)
FluxT.fromOptional(Optional.of(Flux.just(10))
.peek(System.out::println);
//prints 10
public FluxTValue<T> filter(java.util.function.Predicate<? super T> test)
FluxT.fromOptional(Optional.of(Flux.just(10,11))
.filter(t->t!=10);
filter in interface FluxT<T>filter in interface Filterable<T>filter in interface FilterableFunctor<T>test - Predicate to filter the wrapped Fluxpublic <B> FluxTValue<B> map(java.util.function.Function<? super T,? extends B> f)
FluxT.fromOptional(Optional.of(Flux.just(10))
.map(t->t=t+1);
public <B> FluxTValue<B> flatMapT(java.util.function.Function<? super T,FluxTValue<? extends B>> f)
FluxT.fromOptional(Optional.of(Flux.just(10))
.flatMap(t->FluxT.fromOptional(Optional.of(Flux.just(t+10)));
f - FlatMap functionpublic <B> FluxTValue<B> flatMap(java.util.function.Function<? super T,? extends reactor.core.publisher.Flux<? extends B>> f)
FluxTpublic static <U,R> java.util.function.Function<FluxTValue<U>,FluxTValue<R>> lift(java.util.function.Function<? super U,? extends R> fn)
public static <A> FluxTValue<A> fromAnyM(AnyMValue<A> anyM)
anyM - AnyM that doesn't contain a monad wrapping an Streampublic static <A> FluxTValue<A> of(AnyMValue<? extends reactor.core.publisher.Flux<A>> monads)
monads - public boolean isStreamPresent()
public reactor.core.publisher.Flux<T> get()
public java.lang.String toString()
toString in class java.lang.Objectpublic java.util.Iterator<T> iterator()
public <U> FluxTValue<U> unitIterator(java.util.Iterator<U> u)
FluxT
FluxT<Integer> fluxT = FluxT.fromIterable(Arrays.asList(Flux.just(1,2,3),Flux.just(4,5,6));
FluxT<String> fluxTStrings = fluxT.unitIterator(Arrays.asList("hello","world").iterator());
//List[Flux["hello","world"]]
unitIterator in interface FluxT<T>u - Iterator over raw values to add to a new Flux Transformerpublic <T> FluxTValue<T> unit(T unit)
FluxT
FluxT<Integer> fluxT = FluxT.fromIterable(Arrays.asList(Flux.just(1,2,3),Flux.just(4,5,6));
FluxT<String> fluxTStrings = fluxT.unit("hello");
//List[Flux["hello"]]
public ReactiveSeq<T> stream()
stream in interface FoldableTransformerSeq<T>stream in interface TransformerSeq<T>stream in interface NestedFoldable<T>stream in interface Sequential<T>stream in interface ConvertableSequence<T>stream in interface ToStream<T>stream in interface Traversable<T>public reactor.core.publisher.Flux<T> flux()
public <R> FluxTValue<R> empty()
public AnyM<? extends IterableFoldable<T>> nestedFoldables()
nestedFoldables in interface NestedFoldable<T>public AnyM<? extends CyclopsCollectable<T>> nestedCollectables()
nestedCollectables in interface NestedCollectable<T>public <T> FluxTValue<T> unitAnyM(AnyM<Traversable<T>> traversable)
unitAnyM in interface TransformerSeq<T>public AnyM<? extends Traversable<T>> transformerStream()
transformerStream in interface TransformerSeq<T>public int hashCode()
hashCode in class java.lang.Objectpublic boolean equals(java.lang.Object o)
equals in class java.lang.Object