T - public abstract class AbstractFluentCollectionX<T> extends java.lang.Object implements LazyFluentCollectionX<T>, ReactorConvertable<T>
| Modifier and Type | Class and Description |
|---|---|
static class |
AbstractFluentCollectionX.LazyCollection<T,C extends java.util.Collection<T>> |
static class |
AbstractFluentCollectionX.PersistentLazyCollection<T,C extends java.util.Collection<T>> |
| Constructor and Description |
|---|
AbstractFluentCollectionX() |
| Modifier and Type | Method and Description |
|---|---|
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> |
cast(java.lang.Class<? extends U> type) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> |
combinations() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> |
combinations(int size) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
combine(java.util.function.BiPredicate<? super T,? super T> predicate,
java.util.function.BinaryOperator<T> op) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
cycle(int times) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
cycle(com.aol.cyclops.Monoid<T> m,
int times) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
cycleUntil(java.util.function.Predicate<? super T> predicate) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
cycleWhile(java.util.function.Predicate<? super T> predicate) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
distinct() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
dropRight(int num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
dropUntil(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
dropWhile(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
filter(java.util.function.Predicate<? super T> pred) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
filterNot(java.util.function.Predicate<? super T> fn) |
<R> com.aol.cyclops.data.collections.extensions.CollectionX<R> |
flatMap(java.util.function.Function<? super T,? extends java.lang.Iterable<? extends R>> mapper) |
abstract reactor.core.publisher.Flux<T> |
flux()
Convert this type to a Reactor Flux
|
abstract <T1> com.aol.cyclops.data.collections.extensions.FluentCollectionX<T1> |
from(java.util.Collection<T1> c) |
<K> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<T>>> |
grouped(java.util.function.Function<? super T,? extends K> classifier) |
<K,A,D> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
intersperse(T value) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
limit(long num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
limitLast(int num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
limitUntil(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
limitWhile(java.util.function.Predicate<? super T> p) |
<R> com.aol.cyclops.data.collections.extensions.CollectionX<R> |
map(java.util.function.Function<? super T,? extends R> mapper) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
minus(java.lang.Object e) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
minusAll(java.util.Collection<?> list) |
LazyFluentCollectionX<T> |
minusAllLazy(java.util.Collection<?> list)
Lazily remove the elements in the supplied Collection from this Collection.
|
LazyFluentCollectionX<T> |
minusLazy(java.lang.Object e)
Lazily remove an element from this Collection.
|
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
notNull() |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> |
ofType(java.lang.Class<? extends U> type) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
onEmpty(T value) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
onEmptyGet(java.util.function.Supplier<? extends T> supplier) |
<X extends java.lang.Throwable> |
onEmptyThrow(java.util.function.Supplier<? extends X> supplier) |
<R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> |
patternMatch(java.util.function.Function<com.aol.cyclops.control.Matchable.CheckValue1<T,R>,com.aol.cyclops.control.Matchable.CheckValue1<T,R>> case1,
java.util.function.Supplier<? extends R> otherwise) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
peek(java.util.function.Consumer<? super T> c) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> |
permutations() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
plus(T e) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
plusAll(java.util.Collection<? extends T> list) |
LazyFluentCollectionX<T> |
plusAllLazy(java.util.Collection<? extends T> list)
Lazily add all the elements in the supplied Collection to this Collection.
|
LazyFluentCollectionX<T> |
plusLazy(T e)
Lazily add an element to this Collection.
|
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
removeAll(java.lang.Iterable<? extends T> it) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
removeAll(org.jooq.lambda.Seq<? extends T> stream) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
removeAll(java.util.stream.Stream<? extends T> stream) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
removeAll(T... values) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
retainAll(java.lang.Iterable<? extends T> it) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
retainAll(org.jooq.lambda.Seq<? extends T> stream) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
retainAll(java.util.stream.Stream<? extends T> stream) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
retainAll(T... values) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
reverse() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
scanLeft(com.aol.cyclops.Monoid<T> monoid) |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> |
scanLeft(U seed,
java.util.function.BiFunction<? super U,? super T,? extends U> function) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
scanRight(com.aol.cyclops.Monoid<T> monoid) |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> |
scanRight(U identity,
java.util.function.BiFunction<? super T,? super U,? extends U> combiner) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
shuffle() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
shuffle(java.util.Random random) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
skip(long num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
skipLast(int num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
skipUntil(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
skipWhile(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
slice(long from,
long to) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
sliding(int windowSize) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> |
sliding(int windowSize,
int increment) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
sorted() |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
abstract <X> com.aol.cyclops.data.collections.extensions.FluentCollectionX<X> |
stream(reactor.core.publisher.Flux<X> stream)
Create a LazyFluentCollection from a Flux.
|
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
takeRight(int num) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
takeUntil(java.util.function.Predicate<? super T> p) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> |
takeWhile(java.util.function.Predicate<? super T> p) |
<R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> |
trampoline(java.util.function.Function<? super T,? extends com.aol.cyclops.control.Trampoline<? extends R>> mapper) |
abstract <U> com.aol.cyclops.types.IterableFunctor<U> |
unitIterator(java.util.Iterator<U> U) |
<T2,R> com.aol.cyclops.types.Zippable<R> |
zip(java.util.function.BiFunction<? super T,? super T2,? extends R> fn,
org.reactivestreams.Publisher<? extends T2> publisher) |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> |
zip(java.lang.Iterable<? extends U> other) |
<U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> |
zip(java.lang.Iterable<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper) |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> |
zip(org.jooq.lambda.Seq<? extends U> other) |
<U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> |
zip(org.jooq.lambda.Seq<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper) |
<U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> |
zip(java.util.stream.Stream<? extends U> other) |
<U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> |
zip(java.util.stream.Stream<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper) |
<S,U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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) |
com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,java.lang.Long>> |
zipWithIndex() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitplusInOrder, unitcollectable, findAny, findFirst, forEach2, forEach2, forEach3, forEach3, fromCollection, getAtIndex, groupBy, head, headAndTail, single, single, singleOptional, streamgroupedStatefullyUntilT, groupedT, groupedUntilT, groupedWhileT, slidingT, slidingTap1, ap2, ap3, ap4, ap5, applicativesflatMapPublisher, flatMapPublisher, flatMapPublisher, mergePublisher, mergePublisherendsWith, endsWithIterable, firstValue, foldRight, foldRight, foldRight, foldRightMapToType, get, join, join, join, mapReduce, mapReduce, print, print, printErr, printOut, reduce, reduce, reduce, reduce, reduce, reduce, reduce, schedule, scheduleFixedDelay, scheduleFixedRate, startsWith, startsWithIterable, toConcurrentLazyCollection, toConcurrentLazyStreamable, toLazyCollection, validate, xMatchfutureOperations, lazyOperations, subscribe, traversableseq, 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, toXorSecondaryadd, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArrayallMatch, anyMatch, avg, avg, avgDouble, avgInt, avgLong, bitAnd, bitAnd, bitAndInt, bitAndLong, bitOr, bitOr, bitOrInt, bitOrLong, collect, commonPrefix, commonSuffix, count, count, countDistinct, countDistinct, countDistinctBy, countDistinctBy, max, max, max, max, maxAll, maxAll, maxAll, maxAll, maxAllBy, maxAllBy, maxBy, maxBy, median, median, medianBy, medianBy, min, min, min, min, minAll, minAll, minAll, minAll, minAllBy, minAllBy, minBy, minBy, mode, modeAll, modeAllBy, modeBy, noneMatch, percentile, percentile, percentileBy, percentileBy, sum, sum, sumDouble, sumInt, sumLong, toCollection, toList, toList, toMap, toMap, toSet, toSet, toString, toStringcollect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collectmonopublic abstract reactor.core.publisher.Flux<T> flux()
ReactorConvertableflux in interface ReactorConvertable<T>public abstract <X> com.aol.cyclops.data.collections.extensions.FluentCollectionX<X> stream(reactor.core.publisher.Flux<X> stream)
LazyFluentCollectionX
LazyListX<Integer> lazyInts = LazyListX.of(1,2,3);
LazyListX<String> lazyStrs = lazyInts.stream(Flux.just("hello","world"));
Calling stream(Flux) on a LazySetX results in a LazySetX etc.
The same collection / reduction method will be used in the newly created Object. I.e. Calling stream(Flux) on
a collection which as an Immutable Collector will result in an Immutable Collection.stream in interface LazyFluentCollectionX<T>stream - Flux to create new collection frompublic LazyFluentCollectionX<T> plusLazy(T e)
LazyFluentCollectionXLazyFluentCollectionX.plus(Object)
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.plusLazy(5);
//Lazy List that will contain [2,4,6,5] when triggered
plusLazy in interface LazyFluentCollectionX<T>e - Element to addpublic com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> plus(T e)
plus in interface com.aol.cyclops.data.collections.extensions.FluentCollectionX<T>plus in interface LazyFluentCollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> plusAll(java.util.Collection<? extends T> list)
plusAll in interface com.aol.cyclops.data.collections.extensions.FluentCollectionX<T>plusAll in interface LazyFluentCollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> minus(java.lang.Object e)
minus in interface com.aol.cyclops.data.collections.extensions.FluentCollectionX<T>minus in interface LazyFluentCollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> minusAll(java.util.Collection<?> list)
minusAll in interface com.aol.cyclops.data.collections.extensions.FluentCollectionX<T>minusAll in interface LazyFluentCollectionX<T>public LazyFluentCollectionX<T> plusAllLazy(java.util.Collection<? extends T> list)
LazyFluentCollectionXLazyFluentCollectionX#plusAll(Object)
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.plusAllLazy(ListX.of(5,10));
//Lazy List that will contain [2,4,6,5,10] when triggered
plusAllLazy in interface LazyFluentCollectionX<T>list - Collection to addpublic LazyFluentCollectionX<T> minusLazy(java.lang.Object e)
LazyFluentCollectionXLazyFluentCollectionX.minus(Object)
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.minusLazy(4);
//Lazy List that will contain [2,6] when triggered
This is an equivalent operation to filtering by equality e.g.
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.filter(i->i==4);
//Lazy List that will contain [2,6] when triggered
minusLazy in interface LazyFluentCollectionX<T>e - Element to removepublic LazyFluentCollectionX<T> minusAllLazy(java.util.Collection<?> list)
LazyFluentCollectionXLazyFluentCollectionX.minusAll(Collection)
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.minusAllLazy(ListX.of(4));
//Lazy List that will contain [2,6] when triggered
This is an equivalent operation to filtering by equality e.g.
LazyListX<Integer> lazy = LazyListX.of(1,2,3)
.map(i->i*2)
.filter(i->ListX.of(4).contains(i));
//Lazy List that will contain [2,6] when triggered
minusAllLazy in interface LazyFluentCollectionX<T>list - of elements to removepublic com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> combine(java.util.function.BiPredicate<? super T,? super T> predicate, java.util.function.BinaryOperator<T> op)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> reverse()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> filter(java.util.function.Predicate<? super T> pred)
public <R> com.aol.cyclops.data.collections.extensions.CollectionX<R> map(java.util.function.Function<? super T,? extends R> mapper)
public <R> com.aol.cyclops.data.collections.extensions.CollectionX<R> flatMap(java.util.function.Function<? super T,? extends java.lang.Iterable<? extends R>> mapper)
flatMap in interface com.aol.cyclops.data.collections.extensions.CollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> limit(long num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> skip(long num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> takeRight(int num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> dropRight(int num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> takeWhile(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> dropWhile(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> takeUntil(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> dropUntil(java.util.function.Predicate<? super T> p)
public <R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> trampoline(java.util.function.Function<? super T,? extends com.aol.cyclops.control.Trampoline<? extends R>> mapper)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> slice(long from, long to)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> grouped(int groupSize)
public <K,A,D> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<T>>> grouped(java.util.function.Function<? super T,? extends K> classifier)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> zip(java.lang.Iterable<? extends U> other)
public <U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> zip(java.lang.Iterable<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> sliding(int windowSize)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> sliding(int windowSize, int increment)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> scanLeft(com.aol.cyclops.Monoid<T> monoid)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> scanLeft(U seed,
java.util.function.BiFunction<? super U,? super T,? extends U> function)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> scanRight(com.aol.cyclops.Monoid<T> monoid)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> scanRight(U identity,
java.util.function.BiFunction<? super T,? super U,? extends U> combiner)
public <U extends java.lang.Comparable<? super U>> com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> sorted(java.util.function.Function<? super T,? extends U> function)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> cycle(int times)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> cycle(com.aol.cyclops.Monoid<T> m, int times)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> cycleWhile(java.util.function.Predicate<? super T> predicate)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> cycleUntil(java.util.function.Predicate<? super T> predicate)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> zip(org.jooq.lambda.Seq<? extends U> other)
public <S,U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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> com.aol.cyclops.data.collections.extensions.FluentCollectionX<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 com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,java.lang.Long>> zipWithIndex()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> distinct()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> sorted()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> sorted(java.util.Comparator<? super T> c)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> skipWhile(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> skipUntil(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> limitWhile(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> limitUntil(java.util.function.Predicate<? super T> p)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> intersperse(T value)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> shuffle()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> skipLast(int num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> limitLast(int num)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> onEmptyGet(java.util.function.Supplier<? extends T> supplier)
public <X extends java.lang.Throwable> com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> onEmptyThrow(java.util.function.Supplier<? extends X> supplier)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> shuffle(java.util.Random random)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> ofType(java.lang.Class<? extends U> type)
ofType in interface com.aol.cyclops.types.Filterable<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> filterNot(java.util.function.Predicate<? super T> fn)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> notNull()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> removeAll(java.util.stream.Stream<? extends T> stream)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> removeAll(org.jooq.lambda.Seq<? extends T> stream)
removeAll in interface com.aol.cyclops.data.collections.extensions.CollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> removeAll(java.lang.Iterable<? extends T> it)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> removeAll(T... values)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> retainAll(java.lang.Iterable<? extends T> it)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> retainAll(java.util.stream.Stream<? extends T> stream)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> retainAll(org.jooq.lambda.Seq<? extends T> stream)
retainAll in interface com.aol.cyclops.data.collections.extensions.CollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> retainAll(T... values)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<U> cast(java.lang.Class<? extends U> type)
public <R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> patternMatch(java.util.function.Function<com.aol.cyclops.control.Matchable.CheckValue1<T,R>,com.aol.cyclops.control.Matchable.CheckValue1<T,R>> case1, java.util.function.Supplier<? extends R> otherwise)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> permutations()
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> combinations(int size)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.control.ReactiveSeq<T>> combinations()
public <C extends java.util.Collection<? super T>> com.aol.cyclops.data.collections.extensions.FluentCollectionX<C> grouped(int size, java.util.function.Supplier<C> supplier)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> groupedUntil(java.util.function.Predicate<? super T> predicate)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<com.aol.cyclops.data.collections.extensions.standard.ListX<T>> groupedWhile(java.util.function.Predicate<? super T> predicate)
public <C extends java.util.Collection<? super T>> com.aol.cyclops.data.collections.extensions.FluentCollectionX<C> groupedWhile(java.util.function.Predicate<? super T> predicate, java.util.function.Supplier<C> factory)
public <C extends java.util.Collection<? super T>> com.aol.cyclops.data.collections.extensions.FluentCollectionX<C> groupedUntil(java.util.function.Predicate<? super T> predicate, java.util.function.Supplier<C> factory)
public com.aol.cyclops.data.collections.extensions.FluentCollectionX<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)
public abstract <T1> com.aol.cyclops.data.collections.extensions.FluentCollectionX<T1> from(java.util.Collection<T1> c)
from in interface com.aol.cyclops.data.collections.extensions.CollectionX<T>public com.aol.cyclops.data.collections.extensions.FluentCollectionX<T> peek(java.util.function.Consumer<? super T> c)
public <U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> zip(org.jooq.lambda.Seq<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper)
public <U,R> com.aol.cyclops.data.collections.extensions.FluentCollectionX<R> zip(java.util.stream.Stream<? extends U> other,
java.util.function.BiFunction<? super T,? super U,? extends R> zipper)
public <U> com.aol.cyclops.data.collections.extensions.FluentCollectionX<org.jooq.lambda.tuple.Tuple2<T,U>> zip(java.util.stream.Stream<? extends U> other)
public abstract <U> com.aol.cyclops.types.IterableFunctor<U> unitIterator(java.util.Iterator<U> U)
unitIterator in interface com.aol.cyclops.types.IterableFunctor<T>