com.aol.cyclops.reactor.transformer

Class MonoTSeq<A>

java.lang.Object

com.aol.cyclops.reactor.transformer.MonoTSeq<A>

Type Parameters:

A - the type of elements held in the nested Monos

All Implemented Interfaces:

com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>, com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>, MonoT<A>, com.aol.cyclops.types.Filterable<A>, com.aol.cyclops.types.Foldable<A>, com.aol.cyclops.types.Functor<A>, com.aol.cyclops.types.IterableFoldable<A>, com.aol.cyclops.types.OnEmpty<A>, com.aol.cyclops.types.Sequential<A>, com.aol.cyclops.types.stream.ConvertableSequence<A>, com.aol.cyclops.types.stream.ConvertableToReactiveSeq<A>, com.aol.cyclops.types.stream.CyclopsCollectable<A>, com.aol.cyclops.types.stream.ToStream<A>, com.aol.cyclops.types.Traversable<A>, com.aol.cyclops.types.Unit<A>, com.aol.cyclops.types.Zippable<A>, java.lang.Iterable<A>, org.jooq.lambda.Collectable<A>, org.reactivestreams.Publisher<A>

public class MonoTSeq<A>
extends java.lang.Object
implements MonoT<A>, com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>, com.aol.cyclops.types.IterableFoldable<A>, com.aol.cyclops.types.stream.ConvertableSequence<A>, com.aol.cyclops.types.stream.CyclopsCollectable<A>, com.aol.cyclops.types.Sequential<A>

Monad Transformer for Reactor Monos nested inside Sequential data types

Method Summary

Modifier and Type	Method and Description
org.jooq.lambda.Collectable<A>	collectable()
MonoTSeq<A>	combine(java.util.function.BiPredicate<? super A,? super A> predicate, java.util.function.BinaryOperator<A> op)
MonoTSeq<A>	cycle(int times)
MonoTSeq<A>	cycle(com.aol.cyclops.Monoid<A> m, int times)
MonoTSeq<A>	cycleUntil(java.util.function.Predicate<? super A> predicate)
MonoTSeq<A>	cycleWhile(java.util.function.Predicate<? super A> predicate)
MonoTSeq<A>	distinct()
MonoTSeq<A>	dropRight(int num)
MonoTSeq<A>	dropUntil(java.util.function.Predicate<? super A> p)
MonoTSeq<A>	dropWhile(java.util.function.Predicate<? super A> p)
<R> MonoTSeq<R>	empty()
boolean	equals(java.lang.Object o)
MonoTSeq<A>	filter(java.util.function.Predicate<? super A> test)
<B> MonoTSeq<B>	flatMap(java.util.function.Function<? super A,? extends com.aol.cyclops.types.MonadicValue<? extends B>> f) flatMap operation
<B> MonoTSeq<B>	flatMapT(java.util.function.Function<? super A,MonoTSeq<B>> f) Flat Map the wrapped Mono
static <A> MonoTSeq<A>	fromAnyM(com.aol.cyclops.types.anyM.AnyMSeq<A> anyM) Construct an MonoT from an AnyM that contains a monad type that contains type other than Mono The values in the underlying monad will be mapped to Mono
<K> MonoTSeq<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<A>>>	grouped(java.util.function.Function<? super A,? extends K> classifier)
<K,T,D> MonoTSeq<org.jooq.lambda.tuple.Tuple2<K,D>>	grouped(java.util.function.Function<? super A,? extends K> classifier, java.util.stream.Collector<? super A,T,D> downstream)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	grouped(int groupSize)
<C extends java.util.Collection<? super A>> MonoTSeq<C>	grouped(int size, java.util.function.Supplier<C> supplier)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	groupedStatefullyUntil(java.util.function.BiPredicate<com.aol.cyclops.data.collections.extensions.standard.ListX<? super A>,? super A> predicate)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	groupedUntil(java.util.function.Predicate<? super A> predicate)
<C extends java.util.Collection<? super A>> MonoTSeq<C>	groupedUntil(java.util.function.Predicate<? super A> predicate, java.util.function.Supplier<C> factory)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	groupedWhile(java.util.function.Predicate<? super A> predicate)
<C extends java.util.Collection<? super A>> MonoTSeq<C>	groupedWhile(java.util.function.Predicate<? super A> predicate, java.util.function.Supplier<C> factory)
int	hashCode()
MonoTSeq<A>	intersperse(A value)
boolean	isSeqPresent()
java.util.Iterator<A>	iterator()
static <U,R> java.util.function.Function<MonoTSeq<U>,MonoTSeq<R>>	lift(java.util.function.Function<? super U,? extends R> fn) Lift a function into one that accepts and returns an MonoT This allows multiple monad types to add functionality to existing functions and methods e.g.
static <U1,U2,R> java.util.function.BiFunction<MonoTSeq<U1>,MonoTSeq<U2>,MonoTSeq<R>>	lift2(java.util.function.BiFunction<? super U1,? super U2,? extends R> fn) Lift a BiFunction into one that accepts and returns MonoTs This allows multiple monad types to add functionality to existing functions and methods e.g.
MonoTSeq<A>	limit(long num)
MonoTSeq<A>	limitLast(int num)
MonoTSeq<A>	limitUntil(java.util.function.Predicate<? super A> p)
MonoTSeq<A>	limitWhile(java.util.function.Predicate<? super A> p)
<B> MonoTSeq<B>	map(java.util.function.Function<? super A,? extends B> f) Map the wrapped Mono
static <A> MonoTSeq<A>	of(com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Mono<A>> monads) Construct an MonoT from an AnyM that wraps a monad containing Monos
static <A> MonoTSeq<A>	of(reactor.core.publisher.Mono<A> mono) Construct a MonoTSeq containing the supplied Mono inside a List
MonoTSeq<A>	onEmpty(A value)
MonoTSeq<A>	onEmptyGet(java.util.function.Supplier<? extends A> supplier)
<X extends java.lang.Throwable> MonoTSeq<A>	onEmptyThrow(java.util.function.Supplier<? extends X> supplier)
MonoTSeq<A>	peek(java.util.function.Consumer<? super A> peek) Peek at the current value of the Mono
MonoTSeq<A>	reverse()
MonoTSeq<A>	scanLeft(com.aol.cyclops.Monoid<A> monoid)
<U> MonoTSeq<U>	scanLeft(U seed, java.util.function.BiFunction<? super U,? super A,? extends U> function)
MonoTSeq<A>	scanRight(com.aol.cyclops.Monoid<A> monoid)
<U> MonoTSeq<U>	scanRight(U identity, java.util.function.BiFunction<? super A,? super U,? extends U> combiner)
MonoTSeq<A>	shuffle()
MonoTSeq<A>	shuffle(java.util.Random random)
MonoTSeq<A>	skip(long num)
MonoTSeq<A>	skipLast(int num)
MonoTSeq<A>	skipUntil(java.util.function.Predicate<? super A> p)
MonoTSeq<A>	skipWhile(java.util.function.Predicate<? super A> p)
MonoTSeq<A>	slice(long from, long to)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	sliding(int windowSize)
MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>>	sliding(int windowSize, int increment)
MonoTSeq<A>	sorted()
MonoTSeq<A>	sorted(java.util.Comparator<? super A> c)
<U extends java.lang.Comparable<? super U>> MonoTSeq<A>	sorted(java.util.function.Function<? super A,? extends U> function)
com.aol.cyclops.control.ReactiveSeq<A>	stream()
MonoTSeq<A>	takeRight(int num)
MonoTSeq<A>	takeUntil(java.util.function.Predicate<? super A> p)
MonoTSeq<A>	takeWhile(java.util.function.Predicate<? super A> p)
java.lang.String	toString()
com.aol.cyclops.types.anyM.AnyMSeq<? extends com.aol.cyclops.types.Traversable<A>>	transformerStream()
<R> MonoTSeq<R>	unit(R value)
<T> MonoTSeq<T>	unitAnyM(com.aol.cyclops.control.AnyM<com.aol.cyclops.types.Traversable<T>> traversable)
<R> MonoTSeq<R>	unitIterator(java.util.Iterator<R> it)
<T> MonoTSeq<T>	unitStream(com.aol.cyclops.control.ReactiveSeq<T> traversable)
com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Mono<A>>	unwrap()
<U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>>	zip(java.lang.Iterable<? extends U> other)
<U,R> MonoTSeq<R>	zip(java.lang.Iterable<? extends U> other, java.util.function.BiFunction<? super A,? super U,? extends R> zipper)
<U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>>	zip(org.jooq.lambda.Seq<? extends U> other)
<U,R> MonoTSeq<R>	zip(org.jooq.lambda.Seq<? extends U> other, java.util.function.BiFunction<? super A,? super U,? extends R> zipper)
<U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>>	zip(java.util.stream.Stream<? extends U> other)
<U,R> MonoTSeq<R>	zip(java.util.stream.Stream<? extends U> other, java.util.function.BiFunction<? super A,? super U,? extends R> zipper)
<S,U> MonoTSeq<org.jooq.lambda.tuple.Tuple3<A,S,U>>	zip3(java.util.stream.Stream<? extends S> second, java.util.stream.Stream<? extends U> third)
<T2,T3,T4> MonoTSeq<org.jooq.lambda.tuple.Tuple4<A,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)
MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,java.lang.Long>>	zipWithIndex()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.aol.cyclops.reactor.transformer.MonoT

bind, cast, emptyList, emptyOptional, filterNot, fromAnyM, fromAnyMSeq, fromAnyMValue, fromFuture, fromIterable, fromIterableValue, fromMono, fromOptional, fromPublisher, fromStream, fromValue, notNull, of, ofType, patternMatch, trampoline

Methods inherited from interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq

subscribe

Methods inherited from interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq

futureOperations, lazyOperations

Methods inherited from interface com.aol.cyclops.types.stream.ConvertableSequence

seq, 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, toXorSecondary

Methods inherited from interface com.aol.cyclops.types.Traversable

traversable

Methods inherited from interface com.aol.cyclops.types.Zippable

zip

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.aol.cyclops.types.Sequential

fixedDelay, onePer, xPer

Methods inherited from interface com.aol.cyclops.types.stream.ToStream

futureStream, getStreamable, isEmpty, jdkStream, reactiveSeq, reveresedJDKStream, reveresedStream

Methods inherited from interface com.aol.cyclops.types.IterableFoldable

foldable, headAndTail, visit

Methods inherited from interface com.aol.cyclops.types.Foldable

endsWith, endsWithIterable, findAny, findFirst, firstValue, foldRight, foldRight, foldRight, foldRightMapToType, get, groupBy, join, join, join, mapReduce, mapReduce, print, print, printErr, printOut, reduce, reduce, reduce, reduce, reduce, reduce, reduce, schedule, scheduleFixedDelay, scheduleFixedRate, single, single, singleOptional, startsWith, startsWithIterable, toConcurrentLazyCollection, toConcurrentLazyStreamable, toLazyCollection, validate, xMatch

Methods inherited from interface com.aol.cyclops.types.stream.CyclopsCollectable

allMatch, 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, toString

Methods inherited from interface org.jooq.lambda.Collectable

collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect, collect

Method Detail

unwrap

public com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Mono<A>> unwrap()

Specified by:

unwrap in interface MonoT<A>

Returns:

The wrapped AnyM

unitStream

public <T> MonoTSeq<T> unitStream(com.aol.cyclops.control.ReactiveSeq<T> traversable)

Specified by:

unitStream in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

unitAnyM

public <T> MonoTSeq<T> unitAnyM(com.aol.cyclops.control.AnyM<com.aol.cyclops.types.Traversable<T>> traversable)

Specified by:

unitAnyM in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

transformerStream

public com.aol.cyclops.types.anyM.AnyMSeq<? extends com.aol.cyclops.types.Traversable<A>> transformerStream()

Specified by:

transformerStream in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

filter

public MonoTSeq<A> filter(java.util.function.Predicate<? super A> test)

Specified by:

filter in interface MonoT<A>

Specified by:

filter in interface com.aol.cyclops.types.Filterable<A>

peek

public MonoTSeq<A> peek(java.util.function.Consumer<? super A> peek)

Description copied from interface: MonoT

Peek at the current value of the Mono

  
    MonoT.of(AnyM.fromIterable(ListX.of(Mono.just(10)))
             .peek(System.out::println);
             
     //prints 10        
 
 

Specified by:

peek in interface MonoT<A>

Specified by:

peek in interface com.aol.cyclops.types.Functor<A>

Parameters:

peek - Consumer to accept current value of CompletableFuture

Returns:

CompletableFutureT with peek call

map

public <B> MonoTSeq<B> map(java.util.function.Function<? super A,? extends B> f)

Description copied from interface: MonoT

Map the wrapped Mono

  
   MonoT.of(AnyM.fromIterable(ListX.of(Mono.just(10)))
             .map(t->t+1);
  
  
 
 

Specified by:

map in interface MonoT<A>

Specified by:

map in interface com.aol.cyclops.types.Functor<A>

Parameters:

f - Mapping function for the wrapped Mono

Returns:

CompletableFutureT that applies the map function to the wrapped Mono

flatMapT

public <B> MonoTSeq<B> flatMapT(java.util.function.Function<? super A,MonoTSeq<B>> f)

Flat Map the wrapped Mono

  
  MonoT.of(AnyM.fromStream(Arrays.asMono(10))
             .flatMap(t->Mono.completedFuture(20));
  
  
  //MonoT<AnyMSeq<Stream<Mono[20]>>>
 
 

Parameters:

f - FlatMap function

Returns:

MonoT that applies the flatMap function to the wrapped Mono

flatMap

public <B> MonoTSeq<B> flatMap(java.util.function.Function<? super A,? extends com.aol.cyclops.types.MonadicValue<? extends B>> f)

Description copied from interface: MonoT

flatMap operation

  
   MonoT.of(AnyM.fromIterable(ListX.of(Mono.just(10)))
             .flatMap(t-> Maybe.just(t+1));
  
  
 
 

Specified by:

flatMap in interface MonoT<A>

Parameters:

f - Mapping function

Returns:

flatMapped MonoT

lift

public static <U,R> java.util.function.Function<MonoTSeq<U>,MonoTSeq<R>> lift(java.util.function.Function<? super U,? extends R> fn)

Lift a function into one that accepts and returns an MonoT This allows multiple monad types to add functionality to existing functions and methods e.g. to add list handling / iteration (via Mono) and iteration (via Stream) to an existing function

Specified by:

lift in interface MonoT<A>

Parameters:

fn - Function to enhance with functionality from Mono and another monad type

Returns:

Function that accepts and returns an MonoT

lift2

public static <U1,U2,R> java.util.function.BiFunction<MonoTSeq<U1>,MonoTSeq<U2>,MonoTSeq<R>> lift2(java.util.function.BiFunction<? super U1,? super U2,? extends R> fn)

Lift a BiFunction into one that accepts and returns MonoTs This allows multiple monad types to add functionality to existing functions and methods e.g. to add list handling / iteration (via Mono), iteration (via Stream) and asynchronous execution (Mono) to an existing function

Specified by:

lift2 in interface MonoT<A>

Parameters:

fn - BiFunction to enhance with functionality from Mono and another monad type

Returns:

Function that accepts and returns an MonoT

fromAnyM

public static <A> MonoTSeq<A> fromAnyM(com.aol.cyclops.types.anyM.AnyMSeq<A> anyM)

Construct an MonoT from an AnyM that contains a monad type that contains type other than Mono The values in the underlying monad will be mapped to Mono

Parameters:

anyM - AnyM that doesn't contain a monad wrapping an Mono

Returns:

MonoT

of

public static <A> MonoTSeq<A> of(com.aol.cyclops.types.anyM.AnyMSeq<reactor.core.publisher.Mono<A>> monads)

Construct an MonoT from an AnyM that wraps a monad containing Monos

Parameters:

monads - AnyM that contains a monad wrapping an Mono

Returns:

MonoT

of

public static <A> MonoTSeq<A> of(reactor.core.publisher.Mono<A> mono)

Construct a MonoTSeq containing the supplied Mono inside a List

Parameters:

mono - Mono to nest inside a List

Returns:

MonoTSeq wrapping a List containing a Mono

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

stream

public com.aol.cyclops.control.ReactiveSeq<A> stream()

Specified by:

stream in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

stream in interface com.aol.cyclops.types.Foldable<A>

Specified by:

stream in interface com.aol.cyclops.types.Sequential<A>

Specified by:

stream in interface com.aol.cyclops.types.stream.ConvertableSequence<A>

Specified by:

stream in interface com.aol.cyclops.types.stream.ToStream<A>

Specified by:

stream in interface com.aol.cyclops.types.Traversable<A>

iterator

public java.util.Iterator<A> iterator()

Specified by:

iterator in interface com.aol.cyclops.types.stream.ToStream<A>

Specified by:

iterator in interface java.lang.Iterable<A>

unitIterator

public <R> MonoTSeq<R> unitIterator(java.util.Iterator<R> it)

unit

public <R> MonoTSeq<R> unit(R value)

Specified by:

unit in interface com.aol.cyclops.types.Unit<A>

empty

public <R> MonoTSeq<R> empty()

Specified by:

empty in interface MonoT<A>

Returns:

An empty MonoT instance

collectable

public org.jooq.lambda.Collectable<A> collectable()

Specified by:

collectable in interface com.aol.cyclops.types.stream.CyclopsCollectable<A>

isSeqPresent

public boolean isSeqPresent()

Specified by:

isSeqPresent in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

combine

public MonoTSeq<A> combine(java.util.function.BiPredicate<? super A,? super A> predicate,
                           java.util.function.BinaryOperator<A> op)

Specified by:

combine in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

combine in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

combine in interface com.aol.cyclops.types.Traversable<A>

cycle

public MonoTSeq<A> cycle(int times)

Specified by:

cycle in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

cycle in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

cycle in interface com.aol.cyclops.types.Traversable<A>

cycle

public MonoTSeq<A> cycle(com.aol.cyclops.Monoid<A> m,
                         int times)

Specified by:

cycle in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

cycle in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

cycle in interface com.aol.cyclops.types.Traversable<A>

cycleWhile

public MonoTSeq<A> cycleWhile(java.util.function.Predicate<? super A> predicate)

Specified by:

cycleWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

cycleWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

cycleWhile in interface com.aol.cyclops.types.Traversable<A>

cycleUntil

public MonoTSeq<A> cycleUntil(java.util.function.Predicate<? super A> predicate)

Specified by:

cycleUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

cycleUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

cycleUntil in interface com.aol.cyclops.types.Traversable<A>

zip

public <U,R> MonoTSeq<R> zip(java.lang.Iterable<? extends U> other,
                             java.util.function.BiFunction<? super A,? super U,? extends R> zipper)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip

public <U,R> MonoTSeq<R> zip(java.util.stream.Stream<? extends U> other,
                             java.util.function.BiFunction<? super A,? super U,? extends R> zipper)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip

public <U,R> MonoTSeq<R> zip(org.jooq.lambda.Seq<? extends U> other,
                             java.util.function.BiFunction<? super A,? super U,? extends R> zipper)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip

public <U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>> zip(java.util.stream.Stream<? extends U> other)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip

public <U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>> zip(java.lang.Iterable<? extends U> other)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip

public <U> MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,U>> zip(org.jooq.lambda.Seq<? extends U> other)

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip in interface com.aol.cyclops.types.Traversable<A>

Specified by:

zip in interface com.aol.cyclops.types.Zippable<A>

zip3

public <S,U> MonoTSeq<org.jooq.lambda.tuple.Tuple3<A,S,U>> zip3(java.util.stream.Stream<? extends S> second,
                                                                java.util.stream.Stream<? extends U> third)

Specified by:

zip3 in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip3 in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip3 in interface com.aol.cyclops.types.Traversable<A>

zip4

public <T2,T3,T4> MonoTSeq<org.jooq.lambda.tuple.Tuple4<A,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)

Specified by:

zip4 in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zip4 in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zip4 in interface com.aol.cyclops.types.Traversable<A>

zipWithIndex

public MonoTSeq<org.jooq.lambda.tuple.Tuple2<A,java.lang.Long>> zipWithIndex()

Specified by:

zipWithIndex in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

zipWithIndex in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

zipWithIndex in interface com.aol.cyclops.types.Traversable<A>

sliding

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> sliding(int windowSize)

Specified by:

sliding in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

sliding in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

sliding in interface com.aol.cyclops.types.Traversable<A>

sliding

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> sliding(int windowSize,
                                                                                       int increment)

Specified by:

sliding in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

sliding in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

sliding in interface com.aol.cyclops.types.Traversable<A>

grouped

public <C extends java.util.Collection<? super A>> MonoTSeq<C> grouped(int size,
                                                                       java.util.function.Supplier<C> supplier)

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.types.Traversable<A>

groupedUntil

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> groupedUntil(java.util.function.Predicate<? super A> predicate)

Specified by:

groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

groupedUntil in interface com.aol.cyclops.types.Traversable<A>

groupedStatefullyUntil

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> groupedStatefullyUntil(java.util.function.BiPredicate<com.aol.cyclops.data.collections.extensions.standard.ListX<? super A>,? super A> predicate)

Specified by:

groupedStatefullyUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

groupedStatefullyUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

groupedStatefullyUntil in interface com.aol.cyclops.types.Traversable<A>

groupedWhile

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> groupedWhile(java.util.function.Predicate<? super A> predicate)

Specified by:

groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

groupedWhile in interface com.aol.cyclops.types.Traversable<A>

groupedWhile

public <C extends java.util.Collection<? super A>> MonoTSeq<C> groupedWhile(java.util.function.Predicate<? super A> predicate,
                                                                            java.util.function.Supplier<C> factory)

Specified by:

groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

groupedWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

groupedWhile in interface com.aol.cyclops.types.Traversable<A>

groupedUntil

public <C extends java.util.Collection<? super A>> MonoTSeq<C> groupedUntil(java.util.function.Predicate<? super A> predicate,
                                                                            java.util.function.Supplier<C> factory)

Specified by:

groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

groupedUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

groupedUntil in interface com.aol.cyclops.types.Traversable<A>

grouped

public MonoTSeq<com.aol.cyclops.data.collections.extensions.standard.ListX<A>> grouped(int groupSize)

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.types.Traversable<A>

grouped

public <K,T,D> MonoTSeq<org.jooq.lambda.tuple.Tuple2<K,D>> grouped(java.util.function.Function<? super A,? extends K> classifier,
                                                                   java.util.stream.Collector<? super A,T,D> downstream)

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.types.Traversable<A>

grouped

public <K> MonoTSeq<org.jooq.lambda.tuple.Tuple2<K,org.jooq.lambda.Seq<A>>> grouped(java.util.function.Function<? super A,? extends K> classifier)

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

grouped in interface com.aol.cyclops.types.Traversable<A>

distinct

public MonoTSeq<A> distinct()

Specified by:

distinct in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

distinct in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

distinct in interface com.aol.cyclops.types.Traversable<A>

scanLeft

public MonoTSeq<A> scanLeft(com.aol.cyclops.Monoid<A> monoid)

Specified by:

scanLeft in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

scanLeft in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

scanLeft in interface com.aol.cyclops.types.Traversable<A>

scanLeft

public <U> MonoTSeq<U> scanLeft(U seed,
                                java.util.function.BiFunction<? super U,? super A,? extends U> function)

Specified by:

scanLeft in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

scanLeft in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

scanLeft in interface com.aol.cyclops.types.Traversable<A>

scanRight

public MonoTSeq<A> scanRight(com.aol.cyclops.Monoid<A> monoid)

Specified by:

scanRight in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

scanRight in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

scanRight in interface com.aol.cyclops.types.Traversable<A>

scanRight

public <U> MonoTSeq<U> scanRight(U identity,
                                 java.util.function.BiFunction<? super A,? super U,? extends U> combiner)

Specified by:

scanRight in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

scanRight in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

scanRight in interface com.aol.cyclops.types.Traversable<A>

sorted

public MonoTSeq<A> sorted()

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.types.Traversable<A>

sorted

public MonoTSeq<A> sorted(java.util.Comparator<? super A> c)

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.types.Traversable<A>

takeWhile

public MonoTSeq<A> takeWhile(java.util.function.Predicate<? super A> p)

Specified by:

takeWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

takeWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

takeWhile in interface com.aol.cyclops.types.Traversable<A>

dropWhile

public MonoTSeq<A> dropWhile(java.util.function.Predicate<? super A> p)

Specified by:

dropWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

dropWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

dropWhile in interface com.aol.cyclops.types.Traversable<A>

takeUntil

public MonoTSeq<A> takeUntil(java.util.function.Predicate<? super A> p)

Specified by:

takeUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

takeUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

takeUntil in interface com.aol.cyclops.types.Traversable<A>

dropUntil

public MonoTSeq<A> dropUntil(java.util.function.Predicate<? super A> p)

Specified by:

dropUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

dropUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

dropUntil in interface com.aol.cyclops.types.Traversable<A>

dropRight

public MonoTSeq<A> dropRight(int num)

Specified by:

dropRight in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

dropRight in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

dropRight in interface com.aol.cyclops.types.Traversable<A>

takeRight

public MonoTSeq<A> takeRight(int num)

Specified by:

takeRight in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

takeRight in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

takeRight in interface com.aol.cyclops.types.Traversable<A>

skip

public MonoTSeq<A> skip(long num)

Specified by:

skip in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

skip in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

skip in interface com.aol.cyclops.types.Traversable<A>

skipWhile

public MonoTSeq<A> skipWhile(java.util.function.Predicate<? super A> p)

Specified by:

skipWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

skipWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

skipWhile in interface com.aol.cyclops.types.Traversable<A>

skipUntil

public MonoTSeq<A> skipUntil(java.util.function.Predicate<? super A> p)

Specified by:

skipUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

skipUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

skipUntil in interface com.aol.cyclops.types.Traversable<A>

limit

public MonoTSeq<A> limit(long num)

Specified by:

limit in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

limit in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

limit in interface com.aol.cyclops.types.Traversable<A>

limitWhile

public MonoTSeq<A> limitWhile(java.util.function.Predicate<? super A> p)

Specified by:

limitWhile in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

limitWhile in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

limitWhile in interface com.aol.cyclops.types.Traversable<A>

limitUntil

public MonoTSeq<A> limitUntil(java.util.function.Predicate<? super A> p)

Specified by:

limitUntil in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

limitUntil in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

limitUntil in interface com.aol.cyclops.types.Traversable<A>

intersperse

public MonoTSeq<A> intersperse(A value)

Specified by:

intersperse in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

intersperse in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

intersperse in interface com.aol.cyclops.types.Traversable<A>

reverse

public MonoTSeq<A> reverse()

Specified by:

reverse in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

reverse in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

reverse in interface com.aol.cyclops.types.Traversable<A>

shuffle

public MonoTSeq<A> shuffle()

Specified by:

shuffle in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

shuffle in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

shuffle in interface com.aol.cyclops.types.Traversable<A>

skipLast

public MonoTSeq<A> skipLast(int num)

Specified by:

skipLast in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

skipLast in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

skipLast in interface com.aol.cyclops.types.Traversable<A>

limitLast

public MonoTSeq<A> limitLast(int num)

Specified by:

limitLast in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

limitLast in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

limitLast in interface com.aol.cyclops.types.Traversable<A>

onEmpty

public MonoTSeq<A> onEmpty(A value)

Specified by:

onEmpty in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

onEmpty in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

onEmpty in interface com.aol.cyclops.types.OnEmpty<A>

Specified by:

onEmpty in interface com.aol.cyclops.types.Traversable<A>

onEmptyGet

public MonoTSeq<A> onEmptyGet(java.util.function.Supplier<? extends A> supplier)

Specified by:

onEmptyGet in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

onEmptyGet in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

onEmptyGet in interface com.aol.cyclops.types.OnEmpty<A>

Specified by:

onEmptyGet in interface com.aol.cyclops.types.Traversable<A>

onEmptyThrow

public <X extends java.lang.Throwable> MonoTSeq<A> onEmptyThrow(java.util.function.Supplier<? extends X> supplier)

Specified by:

onEmptyThrow in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

onEmptyThrow in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

onEmptyThrow in interface com.aol.cyclops.types.OnEmpty<A>

Specified by:

onEmptyThrow in interface com.aol.cyclops.types.Traversable<A>

shuffle

public MonoTSeq<A> shuffle(java.util.Random random)

Specified by:

shuffle in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

shuffle in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

shuffle in interface com.aol.cyclops.types.Traversable<A>

slice

public MonoTSeq<A> slice(long from,
                         long to)

Specified by:

slice in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

slice in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

slice in interface com.aol.cyclops.types.Traversable<A>

sorted

public <U extends java.lang.Comparable<? super U>> MonoTSeq<A> sorted(java.util.function.Function<? super A,? extends U> function)

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.TransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.control.monads.transformers.values.ValueTransformerSeq<A>

Specified by:

sorted in interface com.aol.cyclops.types.Traversable<A>

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object