T - the type of elements held in the nested Fluxespublic class FluxTSeq<T> extends java.lang.Object implements FluxT<T>
| Modifier and Type | Method and Description |
|---|---|
FluxTSeq<T> |
combine(java.util.function.BiPredicate<? super T,? super T> predicate,
java.util.function.BinaryOperator<T> op) |
FluxTSeq<T> |
cycle(int times) |
FluxTSeq<T> |
cycle(com.aol.cyclops.Monoid<T> m,
int times) |
FluxTSeq<T> |
cycleUntil(java.util.function.Predicate<? super T> predicate) |
FluxTSeq<T> |
cycleWhile(java.util.function.Predicate<? super T> predicate) |
FluxTSeq<T> |
distinct() |
FluxTSeq<T> |
dropRight(int num) |
FluxTSeq<T> |
dropUntil(java.util.function.Predicate<? super T> p) |
FluxTSeq<T> |
dropWhile(java.util.function.Predicate<? super T> p) |
<R> FluxT<R> |
empty() |
boolean |
equals(java.lang.Object o) |
FluxTSeq<T> |
filter(java.util.function.Predicate<? super T> test)
Filter the wrapped Stream
|
<B> FluxTSeq<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> FluxTSeq<B> |
flatMapT(java.util.function.Function<? super T,FluxTSeq<? extends B>> f)
Flat Map the wrapped Flux
|
reactor.core.publisher.Flux<T> |
flux() |
static <A> FluxTSeq<A> |
fromAnyM(com.aol.cyclops.types.anyM.AnyMSeq<A> anyM)
|
<K> FluxTSeq<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<T>>> |
grouped(java.util.function.Function<? super T,? extends K> classifier) |
<K,A,D> FluxTSeq<org.jooq.lambda.tuple.Tuple2<K,D>> |
grouped(java.util.function.Function<? super T,? extends K> classifier,
java.util.stream.Collector<? super T,A,D> downstream) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
grouped(int groupSize) |
<C extends java.util.Collection<? super T>> |
grouped(int size,
java.util.function.Supplier<C> supplier) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
groupedStatefullyUntil(java.util.function.BiPredicate<com.aol.cyclops.data.collections.extensions.standard.ListX<? super T>,? super T> predicate) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
groupedUntil(java.util.function.Predicate<? super T> predicate) |
<C extends java.util.Collection<? super T>> |
groupedUntil(java.util.function.Predicate<? super T> predicate,
java.util.function.Supplier<C> factory) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
groupedWhile(java.util.function.Predicate<? super T> predicate) |
<C extends java.util.Collection<? super T>> |
groupedWhile(java.util.function.Predicate<? super T> predicate,
java.util.function.Supplier<C> factory) |
int |
hashCode() |
FluxTSeq<T> |
intersperse(T value) |
boolean |
isSeqPresent() |
java.util.Iterator<T> |
iterator() |
static <U,R> java.util.function.Function<FluxTSeq<U>,FluxTSeq<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.
|
FluxTSeq<T> |
limit(long num) |
FluxTSeq<T> |
limitLast(int num) |
FluxTSeq<T> |
limitUntil(java.util.function.Predicate<? super T> p) |
FluxTSeq<T> |
limitWhile(java.util.function.Predicate<? super T> p) |
<B> FluxTSeq<B> |
map(java.util.function.Function<? super T,? extends B> f)
Map the wrapped Stream
|
com.aol.cyclops.control.AnyM<? extends com.aol.cyclops.types.stream.CyclopsCollectable<T>> |
nestedCollectables() |
com.aol.cyclops.control.AnyM<? extends com.aol.cyclops.types.IterableFoldable<T>> |
nestedFoldables() |
static <A> FluxTSeq<A> |
of(com.aol.cyclops.types.anyM.AnyMSeq<? extends reactor.core.publisher.Flux<A>> monads)
Create a FluxT from an AnyM that wraps a monad containing a Stream
|
FluxTSeq<T> |
onEmpty(T value) |
FluxTSeq<T> |
onEmptyGet(java.util.function.Supplier<? extends T> supplier) |
<X extends java.lang.Throwable> |
onEmptyThrow(java.util.function.Supplier<? extends X> supplier) |
FluxTSeq<T> |
peek(java.util.function.Consumer<? super T> peek)
Peek at the current value of the Stream
|
FluxTSeq<T> |
reverse() |
FluxTSeq<T> |
scanLeft(com.aol.cyclops.Monoid<T> monoid) |
<U> FluxTSeq<U> |
scanLeft(U seed,
java.util.function.BiFunction<? super U,? super T,? extends U> function) |
FluxTSeq<T> |
scanRight(com.aol.cyclops.Monoid<T> monoid) |
<U> FluxTSeq<U> |
scanRight(U identity,
java.util.function.BiFunction<? super T,? super U,? extends U> combiner) |
FluxTSeq<T> |
shuffle() |
FluxTSeq<T> |
shuffle(java.util.Random random) |
FluxTSeq<T> |
skip(long num) |
FluxTSeq<T> |
skipLast(int num) |
FluxTSeq<T> |
skipUntil(java.util.function.Predicate<? super T> p) |
FluxTSeq<T> |
skipWhile(java.util.function.Predicate<? super T> p) |
FluxTSeq<T> |
slice(long from,
long to) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
sliding(int windowSize) |
FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
sliding(int windowSize,
int increment) |
FluxTSeq<T> |
sorted() |
FluxTSeq<T> |
sorted(java.util.Comparator<? super T> c) |
<U extends java.lang.Comparable<? super U>> |
sorted(java.util.function.Function<? super T,? extends U> function) |
com.aol.cyclops.control.ReactiveSeq<T> |
stream() |
FluxTSeq<T> |
takeRight(int num) |
FluxTSeq<T> |
takeUntil(java.util.function.Predicate<? super T> p) |
FluxTSeq<T> |
takeWhile(java.util.function.Predicate<? super T> p) |
java.lang.String |
toString() |
com.aol.cyclops.types.anyM.AnyMSeq<? extends com.aol.cyclops.types.Traversable<T>> |
transformerStream() |
<T> FluxTSeq<T> |
unit(T unit)
Create an instance of the same FluxTransformer that contains a Flux with just the value provided
|
<T> FluxTSeq<T> |
unitAnyM(com.aol.cyclops.control.AnyM<com.aol.cyclops.types.Traversable<T>> traversable) |
<R> FluxTSeq<R> |
unitIterator(java.util.Iterator<R> it)
Create an instance of the same FluxTransformer type from the provided Iterator over raw values.
|
com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Flux<T>> |
unwrap() |
<U,R> FluxTSeq<R> |
zip(java.lang.Iterable<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper) |
<U> FluxTSeq<org.jooq.lambda.tuple.Tuple2<T,U>> |
zip(java.util.stream.Stream<? extends U> other) |
<S,U> FluxTSeq<org.jooq.lambda.tuple.Tuple3<T,S,U>> |
zip3(java.util.stream.Stream<? extends S> second,
java.util.stream.Stream<? extends U> third) |
<T2,T3,T4> FluxTSeq<org.jooq.lambda.tuple.Tuple4<T,T2,T3,T4>> |
zip4(java.util.stream.Stream<? extends T2> second,
java.util.stream.Stream<? extends T3> third,
java.util.stream.Stream<? extends T4> fourth) |
FluxTSeq<org.jooq.lambda.tuple.Tuple2<T,java.lang.Long>> |
zipWithIndex() |
clone, finalize, getClass, notify, notifyAll, wait, wait, waitbind, cast, emptyFlux, emptyOptional, filterNot, fluxOfFlux, fromAnyM, fromAnyMSeq, fromAnyMValue, fromFuture, fromIterable, fromIterableValue, fromMono, fromOptional, fromPublisher, fromValue, notNull, of, ofType, patternMatch, trampoline, zip, zip, zip, zipfutureOperations, 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, toXorSecondaryfutureStream, 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, visitpublic boolean isSeqPresent()
isSeqPresent in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>public com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Flux<T>> unwrap()
public FluxTSeq<T> peek(java.util.function.Consumer<? super T> peek)
FluxT.fromIterable(ListX.of(Flux.just(10))
.peek(System.out::println);
//prints 10
public FluxTSeq<T> filter(java.util.function.Predicate<? super T> test)
FluxT.fromIterable(ListX.of(Flux.just(10,11))
.filter(t->t!=10);
//FluxT<[11]>>
public <B> FluxTSeq<B> map(java.util.function.Function<? super T,? extends B> f)
FluxT.of(AnyM.fromStream(Arrays.asStream(Flux.just(10)))
.map(t->t=t+1);
//FluxT<AnyM<Stream<Stream[11]>>>
map in interface FluxT<T>map in interface com.aol.cyclops.types.FilterableFunctor<T>map in interface com.aol.cyclops.types.Functor<T>f - Mapping function for the wrapped Streampublic <B> FluxTSeq<B> flatMapT(java.util.function.Function<? super T,FluxTSeq<? extends B>> f)
FluxT.of(AnyM.fromStream(Arrays.asStream(Flux.just(10)))
.flatMap(t->Flux.just(t+1));
f - FlatMap functionpublic <B> FluxTSeq<B> flatMap(java.util.function.Function<? super T,? extends reactor.core.publisher.Flux<? extends B>> f)
FluxTpublic static <U,R> java.util.function.Function<FluxTSeq<U>,FluxTSeq<R>> lift(java.util.function.Function<? super U,? extends R> fn)
public static <A> FluxTSeq<A> fromAnyM(com.aol.cyclops.types.anyM.AnyMSeq<A> anyM)
anyM - AnyM that doesn't contain a monad wrapping an Streampublic static <A> FluxTSeq<A> of(com.aol.cyclops.types.anyM.AnyMSeq<? extends reactor.core.publisher.Flux<A>> monads)
monads - public java.lang.String toString()
toString in class java.lang.Objectpublic <T> FluxTSeq<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 com.aol.cyclops.control.ReactiveSeq<T> stream()
stream in interface com.aol.cyclops.control.monads.transformers.values.FoldableTransformerSeq<T>stream in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>stream in interface com.aol.cyclops.types.anyM.NestedFoldable<T>stream in interface com.aol.cyclops.types.Sequential<T>stream in interface com.aol.cyclops.types.stream.ConvertableSequence<T>stream in interface com.aol.cyclops.types.stream.ToStream<T>stream in interface com.aol.cyclops.types.Traversable<T>public reactor.core.publisher.Flux<T> flux()
public java.util.Iterator<T> iterator()
public <R> FluxTSeq<R> unitIterator(java.util.Iterator<R> it)
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>it - Iterator over raw values to add to a new Flux Transformerpublic <R> FluxT<R> empty()
public com.aol.cyclops.control.AnyM<? extends com.aol.cyclops.types.IterableFoldable<T>> nestedFoldables()
nestedFoldables in interface com.aol.cyclops.types.anyM.NestedFoldable<T>public com.aol.cyclops.control.AnyM<? extends com.aol.cyclops.types.stream.CyclopsCollectable<T>> nestedCollectables()
nestedCollectables in interface com.aol.cyclops.types.anyM.NestedCollectable<T>public <T> FluxTSeq<T> unitAnyM(com.aol.cyclops.control.AnyM<com.aol.cyclops.types.Traversable<T>> traversable)
unitAnyM in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>public com.aol.cyclops.types.anyM.AnyMSeq<? extends com.aol.cyclops.types.Traversable<T>> transformerStream()
transformerStream in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>public FluxTSeq<T> combine(java.util.function.BiPredicate<? super T,? super T> predicate, java.util.function.BinaryOperator<T> op)
public FluxTSeq<T> cycleWhile(java.util.function.Predicate<? super T> predicate)
cycleWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>cycleWhile in interface FluxT<T>cycleWhile in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<T> cycleUntil(java.util.function.Predicate<? super T> predicate)
cycleUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>cycleUntil in interface FluxT<T>cycleUntil in interface com.aol.cyclops.types.Traversable<T>public <U,R> FluxTSeq<R> zip(java.lang.Iterable<? extends U> other, java.util.function.BiFunction<? super T,? super U,? extends R> zipper)
public <U> FluxTSeq<org.jooq.lambda.tuple.Tuple2<T,U>> zip(java.util.stream.Stream<? extends U> other)
public <S,U> FluxTSeq<org.jooq.lambda.tuple.Tuple3<T,S,U>> zip3(java.util.stream.Stream<? extends S> second, java.util.stream.Stream<? extends U> third)
public <T2,T3,T4> FluxTSeq<org.jooq.lambda.tuple.Tuple4<T,T2,T3,T4>> zip4(java.util.stream.Stream<? extends T2> second, java.util.stream.Stream<? extends T3> third, java.util.stream.Stream<? extends T4> fourth)
public FluxTSeq<org.jooq.lambda.tuple.Tuple2<T,java.lang.Long>> zipWithIndex()
zipWithIndex in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>zipWithIndex in interface FluxT<T>zipWithIndex in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> sliding(int windowSize)
public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> sliding(int windowSize, int increment)
public <C extends java.util.Collection<? super T>> FluxTSeq<C> grouped(int size, java.util.function.Supplier<C> supplier)
public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> groupedUntil(java.util.function.Predicate<? super T> predicate)
groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>groupedUntil in interface FluxT<T>groupedUntil in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> groupedStatefullyUntil(java.util.function.BiPredicate<com.aol.cyclops.data.collections.extensions.standard.ListX<? super T>,? super T> predicate)
groupedStatefullyUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>groupedStatefullyUntil in interface FluxT<T>groupedStatefullyUntil in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> groupedWhile(java.util.function.Predicate<? super T> predicate)
groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>groupedWhile in interface FluxT<T>groupedWhile in interface com.aol.cyclops.types.Traversable<T>public <C extends java.util.Collection<? super T>> FluxTSeq<C> groupedWhile(java.util.function.Predicate<? super T> predicate, java.util.function.Supplier<C> factory)
groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>groupedWhile in interface FluxT<T>groupedWhile in interface com.aol.cyclops.types.Traversable<T>public <C extends java.util.Collection<? super T>> FluxTSeq<C> groupedUntil(java.util.function.Predicate<? super T> predicate, java.util.function.Supplier<C> factory)
groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>groupedUntil in interface FluxT<T>groupedUntil in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> grouped(int groupSize)
public <K,A,D> FluxTSeq<org.jooq.lambda.tuple.Tuple2<K,D>> grouped(java.util.function.Function<? super T,? extends K> classifier, java.util.stream.Collector<? super T,A,D> downstream)
public <K> FluxTSeq<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<T>>> grouped(java.util.function.Function<? super T,? extends K> classifier)
public <U> FluxTSeq<U> scanLeft(U seed, java.util.function.BiFunction<? super U,? super T,? extends U> function)
public <U> FluxTSeq<U> scanRight(U identity, java.util.function.BiFunction<? super T,? super U,? extends U> combiner)
public FluxTSeq<T> limitWhile(java.util.function.Predicate<? super T> p)
limitWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>limitWhile in interface FluxT<T>limitWhile in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<T> limitUntil(java.util.function.Predicate<? super T> p)
limitUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>limitUntil in interface FluxT<T>limitUntil in interface com.aol.cyclops.types.Traversable<T>public FluxTSeq<T> intersperse(T value)
intersperse in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>intersperse in interface FluxT<T>intersperse in interface com.aol.cyclops.types.Traversable<T>public <X extends java.lang.Throwable> FluxTSeq<T> onEmptyThrow(java.util.function.Supplier<? extends X> supplier)
onEmptyThrow in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<T>onEmptyThrow in interface FluxT<T>onEmptyThrow in interface com.aol.cyclops.types.OnEmpty<T>onEmptyThrow in interface com.aol.cyclops.types.Traversable<T>public <U extends java.lang.Comparable<? super U>> FluxTSeq<T> sorted(java.util.function.Function<? super T,? extends U> function)
public int hashCode()
hashCode in class java.lang.Objectpublic boolean equals(java.lang.Object o)
equals in class java.lang.Object