A B C D E F G H I J L M N O P R S T U V W X Z

A

AbstractFluentCollectionX<T> - Class in com.aol.cyclops.reactor.collections.extensions.base

Abstract Class representing a Fluent, Lazy, extended Collection

AbstractFluentCollectionX() - Constructor for class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

AbstractFluentCollectionX.LazyCollection<T,C extends java.util.Collection<T>> - Class in com.aol.cyclops.reactor.collections.extensions.base

AbstractFluentCollectionX.PersistentLazyCollection<T,C extends java.util.Collection<T>> - Class in com.aol.cyclops.reactor.collections.extensions.base

AbstractPushablePublisher<T,X extends com.aol.cyclops.data.async.Adapter<T>,R extends org.reactivestreams.Publisher<T>> - Class in com.aol.cyclops.reactor.flux.pushable

AbstractPushablePublisher(X, R) - Constructor for class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

add(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

add(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

add(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

add(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

addAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

addAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

addAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

addAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

addFirst(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

addLast(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

anyM(Publisher<T>) - Static method in class com.aol.cyclops.control.Publishers

Construct an AnyM type from a Publisher.

anyM(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Construct an AnyM type from a Flux.

anyM(FluxT<T>) - Static method in class com.aol.cyclops.reactor.FluxTs

Construct an AnyM type from a Flux.

anyM(Mono<T>) - Static method in class com.aol.cyclops.reactor.Monos

Construct an AnyM type from a Mono.

anyM(MonoT<T>) - Static method in class com.aol.cyclops.reactor.MonoTs

Construct an AnyM type from a Mono.

B

batchWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.operators.GroupedWhile

bind(Function<? super T, FluxT<? extends B>>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Flat Map the wrapped Flux

bind(Function<? super A, MonoT<? extends B>>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

FlatMap operation

bind(Function<? super A, MonoT<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

C

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cast(Class<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

cast(Class<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

cast(Class<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

clear() - Method in class com.aol.cyclops.control.ReactorPipes

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

clear() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

close(String) - Method in class com.aol.cyclops.control.ReactorPipes

coflatMap(Function<? super MonadicValue<A>, R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

collectable() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

com.aol.cyclops.control - package com.aol.cyclops.control

com.aol.cyclops.reactor - package com.aol.cyclops.reactor

com.aol.cyclops.reactor.collections.extensions.base - package com.aol.cyclops.reactor.collections.extensions.base

com.aol.cyclops.reactor.collections.extensions.persistent - package com.aol.cyclops.reactor.collections.extensions.persistent

com.aol.cyclops.reactor.collections.extensions.standard - package com.aol.cyclops.reactor.collections.extensions.standard

com.aol.cyclops.reactor.comprehenders - package com.aol.cyclops.reactor.comprehenders

com.aol.cyclops.reactor.flux.pushable - package com.aol.cyclops.reactor.flux.pushable

com.aol.cyclops.reactor.operators - package com.aol.cyclops.reactor.operators

com.aol.cyclops.reactor.transformer - package com.aol.cyclops.reactor.transformer

com.aol.cyclops.reactor.types - package com.aol.cyclops.reactor.types

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

combinations(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

combinations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

combine(Flux<T>, BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Combine adjacent elements within a Flux for as long as the supplied predicate holds.

combine(Mono<? extends T1>, Value<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Lazily combine this Mono with the supplied value via the supplied BiFunction

combine(Mono<? extends T1>, Mono<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Lazily combine this Mono with the supplied Mono via the supplied BiFunction

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

combine(BiPredicate<? super T, ? super T>, BinaryOperator<T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

combine(BiPredicate<? super A, ? super A>, BinaryOperator<A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

combine(Value<? extends T2>, BiFunction<? super A, ? super T2, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

combineEager(Monoid<A>, MonadicValue<? extends A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

comparator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

compareTo(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

contains(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

containsAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

count() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

cycle(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cycle(Flux<T>, Monoid<T>, int) - Static method in class com.aol.cyclops.reactor.Fluxes

Convert to a Flux with the result of a reduction operation repeated specified times

cycle(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

cycle(Monoid<T>, int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

cycle(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

cycle(Monoid<T>, int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

cycle(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

cycle(Monoid<A>, int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cycleUntil(Flux<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Repeat in a Stream until specified predicate holds

cycleUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

cycleUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

cycleWhile(Flux<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Repeat in a Flux while specified predicate holds

cycleWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

cycleWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

D

deleteBetween(Flux<T>, int, int) - Static method in class com.aol.cyclops.reactor.Fluxes

Delete elements between given indexes in a Flux

descendingIterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

distinct() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

distinct() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

distinct() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

distinct() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

dropRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

dropRight(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

dropRight(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

dropRight(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

dropUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

dropUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

dropUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

dropWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

dropWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

dropWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

E

efficientOpsOff() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

efficientOpsOn() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

element() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

element() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

element() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

empty() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

empty() - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

empty() - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

empty() - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

empty() - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

empty() - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

empty() - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

empty() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

empty() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

empty() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

empty() - Method in interface com.aol.cyclops.reactor.transformer.MonoT

empty() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

empty() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

emptyFlux() - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

emptyList() - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

emptyOptional() - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

emptyOptional() - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

emptyUnit() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

equals(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

equals(Object) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

equals(Object) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

equals(Object) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

equals(Object) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

executeflatMap(Flux, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

F

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

filter(Flux, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

filter(FluxTSeq, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

filter(FluxTValue, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

filter(Mono, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

filter(MonoTSeq, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

filter(MonoTValue, Predicate) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

filter(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Filter the wrapped Flux

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

Filter the wrapped Stream

filter(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

Filter the wrapped Flux

filter(Predicate<? super A>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

filter(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

filter(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

filterNot(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

filterNot(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

filterNot(Predicate<? super A>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

filterNot(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

first() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

flatMap(Function<? super T, ? extends Iterable<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

flatMap(Flux, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

flatMap(FluxTSeq, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

flatMap(FluxTValue, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

flatMap(Mono, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

flatMap(MonoTSeq, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

flatMap(MonoTValue, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

flatMap(Function<? super T, ? extends Flux<? extends B>>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Perform a flatMap operation on each nested Flux

flatMap(Function<? super T, ? extends Flux<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

flatMap(Function<? super T, ? extends Flux<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

flatMap(Function<? super A, ? extends MonadicValue<? extends B>>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

flatMap operation

flatMap(Function<? super A, ? extends MonadicValue<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

flatMap(Function<? super A, ? extends MonadicValue<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

flatMapT(Function<? super T, FluxTSeq<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

Flat Map the wrapped Flux

flatMapT(Function<? super T, FluxTValue<? extends B>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

Flat Map the wrapped Flux

flatMapT(Function<? super A, MonoTSeq<B>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

Flat Map the wrapped Mono

flatMapT(Function<? super A, MonoTValue<B>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

Flat Map the wrapped CompletableFuture

flux() - Method in class com.aol.cyclops.control.FluxSource

Create a pushable Flux

flux(Adapter<T>) - Static method in class com.aol.cyclops.control.FluxSource

Create a pushable ReactiveSeq

flux(K) - Method in class com.aol.cyclops.control.ReactorPipes

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.LazyCollection

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.PersistentLazyCollection

flux() - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollection

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

flux() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

flux() - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

Create a pushable Flux

flux() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

flux() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

flux() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

flux() - Method in interface com.aol.cyclops.reactor.types.ReactorConvertable

Convert this type to a Reactor Flux

FluxComprehender - Class in com.aol.cyclops.reactor.comprehenders

FluxComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.FluxComprehender

Fluxes - Class in com.aol.cyclops.reactor

Companion class for working with Reactor Flux types

Fluxes() - Constructor for class com.aol.cyclops.reactor.Fluxes

fluxOfFlux() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Convert this FluxTransformer into a Flux of Fluxes

FluxSource - Class in com.aol.cyclops.control

Create Java 8 Streams that data can be pushed into

fluxT(Publisher<Flux<T>>) - Static method in class com.aol.cyclops.reactor.FluxTs

Construct a FluxT from a Publisher containing Fluxes.

FluxT<T> - Interface in com.aol.cyclops.reactor.transformer

Monad Transformer for Reactor Flux types.

FluxTs - Class in com.aol.cyclops.reactor

Companion class for working with FluxTransformers

FluxTs() - Constructor for class com.aol.cyclops.reactor.FluxTs

FluxTSeq<T> - Class in com.aol.cyclops.reactor.transformer

Monad Transformer for Reactor Fluxs nested inside Sequential data types

FluxTSeqComprehender - Class in com.aol.cyclops.reactor.comprehenders

FluxTSeqComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

FluxTValue<T> - Class in com.aol.cyclops.reactor.transformer

Monad Transformer for Reactor Fluxs nested inside Scalar data types

FluxTValueComprehender - Class in com.aol.cyclops.reactor.comprehenders

FluxTValueComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

forEach(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

forEach(Flux<? extends T>, Function<? super T, Flux<R1>>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Perform a For Comprehension over a Flux, accepting an additonal generating function.

forEach(Flux<? extends T>, Function<? super T, ? extends Publisher<R1>>, BiFunction<? super T, ? super R1, Boolean>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

{@code import static com.aol.cyclops.reactor.Fluxes.forEach; forEach(Flux.range(1, 10), i -> Flux.range(i, 10),(a,b) -> a>2 && b<10,Tuple::tuple) .subscribe(System.out::println); //(3, 3) (3, 4) (3, 5) (3, 6) (3, 7) (3, 8) (3, 9) ...

forEach(FluxT<? extends T>, Function<? super T, Publisher<R1>>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting a generating function.

forEach(FluxT<? extends T>, Function<? super T, ? extends Publisher<R1>>, BiFunction<? super T, ? super R1, Boolean>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting a generating function.

forEach(Mono<? extends T>, Function<? super T, Mono<R1>>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting a generating function.

forEach(Mono<? extends T>, Function<? super T, ? extends Mono<R1>>, BiFunction<? super T, ? super R1, Boolean>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting a generating functions.

forEach(MonoT<? extends T>, Function<? super T, Publisher<R1>>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting a generating function.

forEach(MonoT<? extends T>, Function<? super T, ? extends Publisher<R1>>, BiFunction<? super T, ? super R1, Boolean>, BiFunction<? super T, ? super R1, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting a generating function.

forEach3(Flux<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Perform a For Comprehension over a Flux, accepting 2 generating functions.

forEach3(Flux<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, Boolean>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Perform a For Comprehension over a Flux, accepting 2 generating functions.

forEach3(FluxT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting 2 generating functions.

forEach3(FluxT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, Boolean>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting 2 generating functions.

forEach3(Mono<? extends T1>, Function<? super T1, ? extends Mono<R1>>, BiFunction<? super T1, ? super R1, ? extends Mono<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting 2 generating functions.

forEach3(Mono<? extends T1>, Function<? super T1, ? extends Mono<R1>>, BiFunction<? super T1, ? super R1, ? extends Mono<R2>>, TriFunction<? super T1, ? super R1, ? super R2, Boolean>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting 2 generating functions.

forEach3(MonoT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting 2 generating functions.

forEach3(MonoT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, Boolean>, TriFunction<? super T1, ? super R1, ? super R2, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting 2 generating functions.

forEach4(Flux<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Perform a For Comprehension over a Flux, accepting 3 generating functions.

forEach4(Flux<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, Boolean>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Perform a For Comprehension over a Flux, accepting 3 generating functions.

forEach4(FluxT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting 3 generating functions.

forEach4(FluxT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, Boolean>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.FluxTs

Perform a For Comprehension over a FluxT, accepting 3 generating functions.

forEach4(Mono<? extends T1>, Function<? super T1, ? extends Mono<R1>>, BiFunction<? super T1, ? super R1, ? extends Mono<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Mono<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting 3 generating functions.

forEach4(Mono<? extends T1>, Function<? super T1, ? extends Mono<R1>>, BiFunction<? super T1, ? super R1, ? extends Mono<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Mono<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, Boolean>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Perform a For Comprehension over a Mono, accepting 3 generating functions.

forEach4(MonoT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting 3 generating functions.

forEach4(MonoT<? extends T1>, Function<? super T1, ? extends Publisher<R1>>, BiFunction<? super T1, ? super R1, ? extends Publisher<R2>>, TriFunction<? super T1, ? super R1, ? super R2, ? extends Publisher<R3>>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, Boolean>, QuadFunction<? super T1, ? super R1, ? super R2, ? super R3, ? extends R>) - Static method in class com.aol.cyclops.reactor.MonoTs

Perform a For Comprehension over a MonoT, accepting 3 generating functions.

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

from(Collection<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

from(Collection<T1>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

fromAnyM(AnyM<A>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

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

fromAnyM(AnyMSeq<A>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTSeq

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

fromAnyM(AnyMValue<A>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTValue

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

fromAnyM(AnyM<A>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

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

fromAnyM(AnyMSeq<A>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTSeq

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

fromAnyM(AnyMValue<A>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTValue

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

fromAnyMSeq(AnyMSeq<A>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxT from an AnyMSeq by wrapping the elements stored in the AnyMSeq in a Flux

fromAnyMSeq(AnyMSeq<A>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Create a MonoT from an AnyMSeq by wrapping the elements stored in the AnyMSeq in a Mono

fromAnyMValue(AnyMValue<A>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxT from an AnyMValue by wrapping the element stored in the AnyMValue in a Flux

fromAnyMValue(AnyMValue<A>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Create a MonoT from an AnyMValue by wrapping the element stored in the AnyMValue in a Mono

fromFuture(CompletableFuture<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTValue from a JDK CompletableFuture that contains nested Fluxes

fromFuture(CompletableFuture<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTValue from an CompletableFuture containing a Mono

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<PBag<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<POrderedSet<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<PQueue<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<PSet<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<PStack<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Construct LazyPStackX from an Iterable

fromIterable(Reducer<PVector<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Construct a LazyPStackX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Construct LazyListX from an Iterable

fromIterable(Collector<T, ?, Deque<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Construct a LazyListX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Construct LazyListX from an Iterable

fromIterable(Collector<T, ?, List<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Construct a LazyListX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Construct LazyQueueX from an Iterable

fromIterable(Collector<T, ?, Queue<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Construct a LazyQueueX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Construct LazySetX from an Iterable

fromIterable(Collector<T, ?, Set<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Construct a LazySetX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Construct LazySortedSetX from an Iterable

fromIterable(Collector<T, ?, SortedSet<T>>, Iterable<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Construct a LazySortedSetX from an Iterable, using the specified Collector.

fromIterable(Iterable<T>) - Static method in class com.aol.cyclops.reactor.Monos

Construct a Mono from Iterable by taking the first value from Iterable

fromIterable(Iterable<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxT from an Iterable that contains nested Fluxes

fromIterable(Iterable<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Create a MonoTSeq from an Iterable that contains nested Monos

fromIterableValue(Iterable<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTValue from an Iterable that contains nested Fluxes

fromIterableValue(Iterable<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTValue from an Iterable containing a Mono

fromIterator(Iterator) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

fromIterator(Iterator) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

fromIterator(Iterator) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

fromIterator(Iterator) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

fromMono(Mono<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTValue from a Reactor Mono type that contains nested Fluxes

fromMono(Mono<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTValue from a Mono containing a Mono

fromOptional(Optional<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTValue from a JDK Optional that contains nested Fluxes

fromOptional(Optional<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTValue from an Optional containing a Mono

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Construct a LazyPStackX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Construct a LazyListX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Construct a LazyListX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Construct a LazyQueueX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Construct a LazySetX from an Publisher

fromPublisher(Publisher<? extends T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Construct a LazySortedSetX from an Publisher

fromPublisher(Publisher<Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTSeq from a Publisher that contains nested Fluxes

fromPublisher(Publisher<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTSeq from a Publisher containing Monos

fromStream(Stream<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

fromStream(Stream<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

fromStream(Stream<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

fromStream(Stream<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

fromStream(Stream<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

fromStream(Stream<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTSeq from a Stream of Monos

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Create a LazyPStackX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Create a LazyDequeX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Create a LazyListX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Create a LazyQueueX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Create a LazySetX from a Stream

fromStreamS(Stream<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Create a LazySortedSetX from a Stream

fromValue(V) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxTValue from a cyclops-react Value that contains nested Fluxes

fromValue(V) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Construct a MonoTValue from a cyclops-react MonadicValue (Maybe, Eval FutureW etc) containing a Mono

futureStream(LazyReact) - Method in class com.aol.cyclops.control.FluxSource

Create a pushable LazyFutureStream using the supplied ReactPool

futureStream(Adapter<T>, LazyReact) - Static method in class com.aol.cyclops.control.FluxSource

Create a LazyFutureStream.

futureStream(K) - Method in class com.aol.cyclops.control.ReactorPipes

futureStream(K, LazyReact) - Method in class com.aol.cyclops.control.ReactorPipes

futureStream(LazyReact) - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

Create a pushable LazyFutureStream using the supplied ReactPool

G

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Generate a LazyPStackX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Generate a LazyListX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Generate a LazyListX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Generate a LazyQueueX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Generate a LazySetX from the provided Supplier up to the provided limit number of times

generate(long, Supplier<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Generate a LazySortedSetX from the provided Supplier up to the provided limit number of times

get(K) - Method in class com.aol.cyclops.control.ReactorPipes

get() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.LazyCollection

get() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.PersistentLazyCollection

get() - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollection

get(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

get(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

get(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

get(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

get() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

get() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

getFirst() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

getFlux() - Method in class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

getInput() - Method in class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

getInput() - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

getLast() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

getTargetClass() - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

GroupBySize<T,C extends java.util.Collection<? super T>> - Class in com.aol.cyclops.reactor.operators

GroupBySize(Flux<T>) - Constructor for class com.aol.cyclops.reactor.operators.GroupBySize

GroupBySize(Flux<T>, Supplier<C>) - Constructor for class com.aol.cyclops.reactor.operators.GroupBySize

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

grouped(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

grouped(Flux<T>, int, Supplier<C>) - Static method in class com.aol.cyclops.reactor.Fluxes

Batch elements in a Flux by size into a collection created by the supplied factory

grouped(Flux<T>, int) - Static method in class com.aol.cyclops.reactor.Fluxes

Group elements in a Flux

grouped(Flux<T>, Function<? super T, ? extends K>, Collector<? super T, A, D>) - Static method in class com.aol.cyclops.reactor.Fluxes

Classify a Flux by the supplied classifying function, materialize into collection with the supplied Collector

grouped(Flux<T>, Function<? super T, ? extends K>) - Static method in class com.aol.cyclops.reactor.Fluxes

Classify a Flux by the supplied classifying function.

grouped(int) - Method in class com.aol.cyclops.reactor.operators.GroupBySize

grouped(int, Supplier<C>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

grouped(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

grouped(Function<? super T, ? extends K>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

grouped(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

grouped(Function<? super T, ? extends K>, Collector<? super T, A, D>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

grouped(Function<? super T, ? extends K>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

grouped(int, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

grouped(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

grouped(Function<? super A, ? extends K>, Collector<? super A, T, D>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

grouped(Function<? super A, ? extends K>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

groupedStatefullyUntil(Flux<T>, BiPredicate<ListX<? super T>, ? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Create Flux of ListX where each ListX is populated while the supplied bipredicate holds.

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

groupedStatefullyUntil(BiPredicate<ListX<? super T>, ? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

groupedStatefullyUntil(BiPredicate<ListX<? super A>, ? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

groupedUntil(Flux<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Create a Flux batched by List, where each batch is populated while the predicate doesn't hold

groupedUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

groupedUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

groupedUntil(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

groupedUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

groupedUntil(Predicate<? super A>, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

groupedWhile(Flux<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Create a Flux batched by List, where each batch is populated while the predicate holds

groupedWhile(Flux<T>, Predicate<? super T>, Supplier<C>) - Static method in class com.aol.cyclops.reactor.Fluxes

Create a Flux batched by List, where each batch is populated while the predicate holds

GroupedWhile<T,C extends java.util.Collection<? super T>> - Class in com.aol.cyclops.reactor.operators

GroupedWhile(Flux<T>) - Constructor for class com.aol.cyclops.reactor.operators.GroupedWhile

GroupedWhile(Flux<T>, Supplier<C>) - Constructor for class com.aol.cyclops.reactor.operators.GroupedWhile

groupedWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

groupedWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

groupedWhile(Predicate<? super T>, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

groupedWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

groupedWhile(Predicate<? super A>, Supplier<C>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

H

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

hashCode() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

hashCode() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

hashCode() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

hashCode() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

hashCode() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

headSet(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

I

indexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

indexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

indexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

indexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

insertAt(Flux<T>, int, T...) - Static method in class com.aol.cyclops.reactor.Fluxes

Insert data into a Flux at given position

instanceOfT(Object) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

instanceOfT(Object) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

intersperse(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

intersperse(Flux<T>, T) - Static method in class com.aol.cyclops.reactor.Fluxes

Intersperse the supplied value throughout this Flux

intersperse(T) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

intersperse(T) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

intersperse(A) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

isEmpty() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

isPresent() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

isSeqPresent() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

isSeqPresent() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

isSeqPresent() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

isStreamPresent() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

isValuePresent() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Create a LazyPStackX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Create a LazyListX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Create a LazyListX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Create a LazyQueueX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Create a LazySetX by iterative application of a function to an initial element up to the supplied limit number of times

iterate(long, T, UnaryOperator<T>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Create a LazySortedSetX by iterative application of a function to an initial element up to the supplied limit number of times

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

iterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

iterator(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Get a lazy iterator over the data in a Flux

iterator(Mono<T>) - Static method in class com.aol.cyclops.reactor.Monos

Get an Iterator for the value (if any) in the provided Mono

iterator() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

iterator() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

iterator() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

iterator() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

J

jdkStream(Publisher<T>) - Static method in class com.aol.cyclops.control.Publishers

Convert a reactive-streams Publisher to a plain java.util.Stream

L

last() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

lastIndexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

lastIndexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

lastIndexOf(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

LazyCollection() - Constructor for class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.LazyCollection

LazyDequeX<T> - Class in com.aol.cyclops.reactor.collections.extensions.standard

An extended Deque type Deque Extended Deque operations execute lazily e.g.

LazyFluentCollection<T,C extends java.util.Collection<T>> - Interface in com.aol.cyclops.reactor.collections.extensions.base

Interface for a wrapper around a Fluent, Lazy Collection

LazyFluentCollectionX<T> - Interface in com.aol.cyclops.reactor.collections.extensions.base

A Lazy Collection with a fluent api.

LazyListX<T> - Class in com.aol.cyclops.reactor.collections.extensions.standard

An extended List type List Extended List operations execute lazily e.g.

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

lazyListXCollector() - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

LazyPBagX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended Bag type This makes use of PBag (@see org.pcollections.PBag) from PCollectons.

LazyPOrderedSetX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended OrderedSet type Set This makes use of POrderedSet (@see org.pcollections.POrderedSet) from PCollectons.

LazyPQueueX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended Queue type Queue This makes use of PQueue (@see org.pcollections.PQueue) from PCollectons.

LazyPSetX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended Set type Set This makes use of PSet (@see org.pcollections.PSet) from PCollectons.

LazyPStackX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended Persistent List type List This makes use of PStack (@see org.pcollections.PStack) from PCollectons.

LazyPVectorX<T> - Class in com.aol.cyclops.reactor.collections.extensions.persistent

An extended List type List.

LazyQueueX<T> - Class in com.aol.cyclops.reactor.collections.extensions.standard

An extended Queue type Queue Extended Queue operations execute lazily e.g.

LazySetX<T> - Class in com.aol.cyclops.reactor.collections.extensions.standard

An extended Set type Set Extended Set operations execute lazily e.g.

LazySortedSetX<T> - Class in com.aol.cyclops.reactor.collections.extensions.standard

An extended SortedSet type SortedSet Extended SortedSet operations execute lazily e.g.

lift(Function<? super U, ? extends R>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

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.

lift(Function<? super U, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTSeq

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.

lift(Function<? super U, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTValue

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.

lift(Function<? super U, ? extends R>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Lift a function into one that accepts and returns an CompletableFutureT This allows multiple monad types to add functionality to existing functions and methods e.g.

lift(Function<? super U, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTSeq

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.

lift(Function<? super U, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTValue

Lift a function into one that accepts and returns an CompletableFutureT This allows multiple monad types to add functionality to existing functions and methods e.g.

lift2(BiFunction<? super U1, ? super U2, ? extends R>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

Lift a BiFunction into one that accepts and returns CompletableFutureTs This allows multiple monad types to add functionality to existing functions and methods e.g.

lift2(BiFunction<? super U1, ? super U2, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTSeq

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.

lift2(BiFunction<? super U1, ? super U2, ? extends R>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTValue

Lift a BiFunction into one that accepts and returns CompletableFutureTs This allows multiple monad types to add functionality to existing functions and methods e.g.

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

limit(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

limit(long) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

limit(long) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

limit(long) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

limitLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

limitLast(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

limitLast(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

limitLast(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

limitUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

limitUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

limitUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

limitWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

limitWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

limitWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

listIterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

listIterator(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

listIterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

listIterator(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

listIterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

listIterator(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

M

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

map(Flux, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

map(FluxTSeq, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

map(FluxTValue, Function) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

map(Mono, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

map(MonoTSeq, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

map(MonoTValue, Function) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

map(Function<? super T, ? extends B>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Map the wrapped Flux

map(Function<? super T, ? extends B>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

Map the wrapped Stream

map(Function<? super T, ? extends B>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

Map the wrapped Flux

map(Function<? super A, ? extends B>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

Map the wrapped Mono

map(Function<? super A, ? extends B>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

map(Function<? super A, ? extends B>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

minus(Object) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

minus() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

minus(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

minus(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

minus(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

minus(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

minusAll(Collection<?>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

minusAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

minusAllLazy(Collection<?>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

Lazily remove the elements in the supplied Collection from this Collection.

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

minusAllLazy(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

minusLazy(Object) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

Lazily remove an element from this Collection.

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

minusLazy(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

mono() - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

Create a pushable Mono

mono() - Method in interface com.aol.cyclops.reactor.types.ReactorConvertable

Convert this type to a Reactor Mono

MonoComprehender - Class in com.aol.cyclops.reactor.comprehenders

MonoComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.MonoComprehender

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

monoid() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Monos - Class in com.aol.cyclops.reactor

Companion class for working with Reactor Mono types

Monos() - Constructor for class com.aol.cyclops.reactor.Monos

monoT(Publisher<Mono<T>>) - Static method in class com.aol.cyclops.reactor.MonoTs

Construct a MonoT from a Publisher containing Monos.

MonoT<A> - Interface in com.aol.cyclops.reactor.transformer

Monad Transformer for Reactor Mono types.

MonoTs - Class in com.aol.cyclops.reactor

Companion class for working with MonoTransformers

MonoTs() - Constructor for class com.aol.cyclops.reactor.MonoTs

MonoTSeq<A> - Class in com.aol.cyclops.reactor.transformer

Monad Transformer for Reactor Monos nested inside Sequential data types

MonoTSeqComprehender - Class in com.aol.cyclops.reactor.comprehenders

MonoTSeqComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

MonoTValue<A> - Class in com.aol.cyclops.reactor.transformer

MonoTValueComprehender - Class in com.aol.cyclops.reactor.comprehenders

MonoTValueComprehender() - Constructor for class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

MultipleFluxSource<T> - Class in com.aol.cyclops.reactor.flux.pushable

MultipleFluxSource(Queue<T>) - Constructor for class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

N

nest() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

nestedCollectables() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

nestedCollectables() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

nestedFoldables() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

nestedFoldables() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

nextOrNull(K) - Method in class com.aol.cyclops.control.ReactorPipes

Return an Eval that allows retrieval of the next value from the attached pipe when get() is called A value is returned if a value is present, otherwise null is returned if the publisher is complete or an error occurs

nextValue(K) - Method in class com.aol.cyclops.control.ReactorPipes

Return an Eval that allows retrieval of the next value from the attached pipe when get() is called Maybe.some is returned if a value is present, Maybe.none is returned if the publisher is complete or an error occurs

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

notNull() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

notNull() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

notNull() - Method in interface com.aol.cyclops.reactor.transformer.MonoT

notNull() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

O

of(QueueFactory<?>) - Static method in class com.aol.cyclops.control.FluxSource

Create a Pushable Flux source backed by a queue created by the supplied queue factory

of(int) - Static method in class com.aol.cyclops.control.FluxSource

Create a Pushable Flux soure backed by a bounded BlockingQueue.

of() - Static method in class com.aol.cyclops.control.ReactorPipes

of(Map<K, Adapter<V>>) - Static method in class com.aol.cyclops.control.ReactorPipes

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Create a LazyPStackX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Create a LazyListX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Create a LazyListX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Create a LazyQueueX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Create a LazySetX from the specified values

of(T...) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Create a LazySortedSetX from the specified values

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

of(Object) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

of(AnyM<? extends Flux<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.FluxT

Create a FluxT from an AnyM that wraps a monad containing a Flux

of(AnyMSeq<? extends Flux<A>>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTSeq

Create a FluxT from an AnyM that wraps a monad containing a Stream

of(AnyMValue<? extends Flux<A>>) - Static method in class com.aol.cyclops.reactor.transformer.FluxTValue

Create a FluxT from an AnyM that wraps a monad containing a Stream

of(AnyM<Mono<A>>) - Static method in interface com.aol.cyclops.reactor.transformer.MonoT

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

of(AnyMSeq<Mono<A>>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTSeq

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

of(Mono<A>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTSeq

Construct a MonoTSeq containing the supplied Mono inside a List

of(AnyMValue<Mono<A>>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTValue

Construct an CompletableFutureT from an AnyM that wraps a monad containing CompletableFutures

of(Mono<A>) - Static method in class com.aol.cyclops.reactor.transformer.MonoTValue

offer(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

offer(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

offer(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

offerFirst(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

offerLast(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

ofMultiple() - Static method in class com.aol.cyclops.control.FluxSource

ofMultiple(int) - Static method in class com.aol.cyclops.control.FluxSource

ofMultiple(QueueFactory<?>) - Static method in class com.aol.cyclops.control.FluxSource

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

ofType(Flux<T>, Class<? extends U>) - Static method in class com.aol.cyclops.reactor.Fluxes

Keep only those elements in a stream that are of a given type.

ofType(Class<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

ofType(Class<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

ofType(Class<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

ofUnbounded() - Static method in class com.aol.cyclops.control.FluxSource

Create a Pushable Flux source backed by an unbounded ConcurrentLinkedQueue

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

onEmpty(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

onEmpty(Flux<T>, T) - Static method in class com.aol.cyclops.reactor.Fluxes

Generate a lazy Flux containing the supplied value if this Flux is empty

onEmpty(T) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

onEmpty(T) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

onEmpty(A) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

onEmptyGet(Flux<T>, Supplier<? extends T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Generate a lazy Flux containing a value generated from the provided Supplier if this Flux is empty

onEmptyGet(Supplier<? extends T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

onEmptyGet(Supplier<? extends T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

onEmptyGet(Supplier<? extends A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

onEmptySwitch(Supplier<? extends PBag<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

onEmptySwitch(Supplier<? extends POrderedSet<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

onEmptySwitch(Supplier<? extends PQueue<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

onEmptySwitch(Supplier<? extends PSet<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

onEmptySwitch(Supplier<? extends PStack<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

onEmptySwitch(Supplier<? extends PVector<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

onEmptySwitch(Supplier<? extends Deque<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

onEmptySwitch(Supplier<? extends List<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

onEmptySwitch(Supplier<? extends Queue<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

onEmptySwitch(Supplier<? extends Set<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

onEmptySwitch(Supplier<? extends SortedSet<T>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

onEmptySwitch(Flux<T>, Supplier<? extends Flux<T>>) - Static method in class com.aol.cyclops.reactor.Fluxes

Lazily switch a Flux if it is empty if one created by the provided Supplier

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

onEmptyThrow(Flux<T>, Supplier<? extends X>) - Static method in class com.aol.cyclops.reactor.Fluxes

Throw the supplied exception, on first use, if the provided Flux is empty

onEmptyThrow(Supplier<? extends X>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

onEmptyThrow(Supplier<? extends X>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

oneOrError(K) - Method in class com.aol.cyclops.control.ReactorPipes

oneOrErrorAsync(K, Executor) - Method in class com.aol.cyclops.control.ReactorPipes

oneValue(K) - Method in class com.aol.cyclops.control.ReactorPipes

Extract one value from the selected pipe, if it exists

oneValueOrError(K, Class<X>...) - Method in class com.aol.cyclops.control.ReactorPipes

oneValueOrError(K) - Method in class com.aol.cyclops.control.ReactorPipes

P

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

parallelStream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

patternMatch(Flux<T>, Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Static method in class com.aol.cyclops.reactor.Fluxes

Transform the elements of this Stream with a Pattern Matching case and default value

patternMatch(Function<Matchable.CheckValue1<T, R>, Matchable.CheckValue1<T, R>>, Supplier<? extends R>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

patternMatch(Function<Matchable.CheckValue1<A, R>, Matchable.CheckValue1<A, R>>, Supplier<? extends R>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

patternMatch(Function<Matchable.CheckValue1<A, R>, Matchable.CheckValue1<A, R>>, Supplier<? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

peek() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

peek() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

peek() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

peek(Consumer<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Peek at the current value of the Flux

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

Peek at the current value of the Stream

peek(Consumer<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

Peek at the current value of the Flux

peek(Consumer<? super A>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

Peek at the current value of the Mono

peek(Consumer<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

peek(Consumer<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

peekFirst() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

peekFlux(Consumer<? super R>) - Method in class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

peekInput(Consumer<? super X>) - Method in class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

peekLast() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

permutations() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

PersistentLazyCollection() - Constructor for class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX.PersistentLazyCollection

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

plus(T) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plus(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plus(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plus(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

plus(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

plusAll(Collection<? extends T>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plusAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plusAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plusAll(int, Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

plusAll(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

plusAllLazy(Collection<? extends T>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

Lazily add all the elements in the supplied Collection to this Collection.

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

plusAllLazy(Collection<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

plusInOrder(T) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

plusInOrder(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

plusLazy(T) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

Lazily add an element to this Collection.

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

plusLazy(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

poll() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

poll() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

poll() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

pollFirst() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

pollLast() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

pop() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Publishers - Class in com.aol.cyclops.control

Utilities for working with reactive-streams Publishers

Publishers() - Constructor for class com.aol.cyclops.control.Publishers

publishTo(K, Publisher<V>) - Method in class com.aol.cyclops.control.ReactorPipes

publishToAsync(K, Publisher<V>) - Method in class com.aol.cyclops.control.ReactorPipes

push(K, V) - Method in class com.aol.cyclops.control.ReactorPipes

Push the supplied value through the Adapter identified by the supplied key

push(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

PushableFlux<T> - Class in com.aol.cyclops.reactor.flux.pushable

PushableFlux(Queue<T>, Flux<T>) - Constructor for class com.aol.cyclops.reactor.flux.pushable.PushableFlux

PushableMono<T> - Class in com.aol.cyclops.reactor.flux.pushable

PushableMono(Queue<T>, Mono<T>) - Constructor for class com.aol.cyclops.reactor.flux.pushable.PushableMono

R

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Create a LazyPStackX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Create a LazyListX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Create a LazyListX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Create a LazyQueueX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Create a LazySetX that contains the Integers between start and end

range(int, int) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Create a LazySortedSetX that contains the Integers between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Create a LazyPStackX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Create a LazyListX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Create a LazyListX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Create a LazyQueueX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Create a LazySetX that contains the Longs between start and end

rangeLong(long, long) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Create a LazySortedSetX that contains the Longs between start and end

reactiveSeq() - Method in class com.aol.cyclops.control.FluxSource

Create a pushable ReactiveSeq

reactiveSeq(Adapter<T>) - Static method in class com.aol.cyclops.control.FluxSource

Create a pushable ReactiveSeq

reactiveSeq(K) - Method in class com.aol.cyclops.control.ReactorPipes

reactiveSeq() - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

Create a pushable ReactiveSeq

ReactorConvertable<T> - Interface in com.aol.cyclops.reactor.types

Represents a type that can be converted to a Reactor Flux or Mono

ReactorPipes<K,V> - Class in com.aol.cyclops.control

Store for Pipes for cross-thread communication Connected Streams will not be able to complete collect or reduce style methods unless the underlying Adapter for data transfer is closed.

ReactorPipes() - Constructor for class com.aol.cyclops.control.ReactorPipes

register(K, Adapter<V>) - Method in class com.aol.cyclops.control.ReactorPipes

Register a Queue, and get back a listening LazyFutureStream that runs on a single thread (not the calling thread)

registered() - Method in class com.aol.cyclops.control.ReactorPipes

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

remove() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

remove(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

remove(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

remove() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

remove(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

remove() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

remove(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeAll(Flux<T>, Iterable<? extends T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Remove all the values in the supplied Iterable from the Flux

removeFirst() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeFirstOccurrence(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

removeIf(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

removeLast() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

removeLastOccurrence(Object) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

replaceAll(UnaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

replaceAll(UnaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

replaceAll(UnaryOperator<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

resolveForCrossTypeFlatMap(Comprehender, Flux) - Method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

resolveForCrossTypeFlatMap(Comprehender, FluxTSeq) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTSeqComprehender

resolveForCrossTypeFlatMap(Comprehender, FluxTValue) - Method in class com.aol.cyclops.reactor.comprehenders.FluxTValueComprehender

resolveForCrossTypeFlatMap(Comprehender, Mono) - Method in class com.aol.cyclops.reactor.comprehenders.MonoComprehender

resolveForCrossTypeFlatMap(Comprehender, MonoTSeq) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTSeqComprehender

resolveForCrossTypeFlatMap(Comprehender, MonoTValue) - Method in class com.aol.cyclops.reactor.comprehenders.MonoTValueComprehender

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

retainAll(Collection<?>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

retainAll(Iterable<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

retainAll(Stream<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

retainAll(Seq<? extends T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

retainAll(T...) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

retainAll(Flux<T>, Iterable<? extends T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Retain only the values in the supplied Iterable in the generated Flux

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

reverse() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

reverse(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Lazily reverse a Flux by materializing it on first use and iterating over the materialized collection in reverse order

reverse() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

reverse() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

reverse() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

S

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

scanLeft(Monoid<T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

scanLeft(Monoid<T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

scanLeft(U, BiFunction<? super U, ? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

scanLeft(Monoid<A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

scanLeft(U, BiFunction<? super U, ? super A, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

scanRight(Flux<T>, U, BiFunction<? super T, ? super U, ? extends U>) - Static method in class com.aol.cyclops.reactor.Fluxes

Apply the identity function / combiner from left to right accumulating partial results in the resulting Flux This is a lazy operation that materializes the provided Flux in order to reverse it on first use.

scanRight(Flux<T>, Monoid<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

scanRight(Monoid<T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

scanRight(Monoid<T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

scanRight(U, BiFunction<? super T, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

scanRight(Monoid<A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

scanRight(U, BiFunction<? super A, ? super U, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

set(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

set(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

set(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

shuffle() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

shuffle(Random) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

shuffle(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Lazily shuffle a Flux by materializing it on first use & shuffling it

shuffle(Flux<T>, Random) - Static method in class com.aol.cyclops.reactor.Fluxes

Lazily shuffle a Flux by materializing it on first use & shuffling it using the supplied Random number generator

shuffle() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

shuffle(Random) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

shuffle() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

shuffle(Random) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

shuffle() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

shuffle(Random) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Construct a LazyPStackX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

Construct a LazyListX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Construct a LazyListX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Construct a LazyQueueX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Construct a LazySetX with a single value

singleton(T) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Construct a LazySortedSetX with a single value

size() - Method in class com.aol.cyclops.control.ReactorPipes

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

size() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

skip(long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

skip(long) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

skip(long) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

skip(long) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

skipLast(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

skipLast(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

skipLast(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

skipLast(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

skipUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

skipUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

skipWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

skipWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

slice(long, long) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

slice(long, long) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

slice(long, long) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

slice(long, long) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

sliding(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

sliding(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

sliding(Flux<T>, int, int) - Static method in class com.aol.cyclops.reactor.Fluxes

Create a sliding view over this Sequence

sliding(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

sliding(int, int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

sliding(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

sliding(int, int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

sliding(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

sliding(int, int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

sort(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sort(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sort(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

sorted() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

sorted(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Lazily shuffle a Flux by materializing it on first use & sorting it

sorted(Flux<T>, Function<? super T, ? extends U>) - Static method in class com.aol.cyclops.reactor.Fluxes

Sort the Flux using the supplied Function.

sorted(Flux<T>, Comparator<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Sort Flux using the provided comparator This is a lazy operation that materializes the provided Flux on first use in order to sort it.

sorted() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

sorted(Comparator<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

sorted(Function<? super T, ? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

sorted() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

sorted(Comparator<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

sorted() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

sorted(Comparator<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

sorted(Function<? super A, ? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

spliterator() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

stream() - Method in class com.aol.cyclops.control.FluxSource

Create a pushable JDK 8 Stream

stream(Adapter<T>) - Static method in class com.aol.cyclops.control.FluxSource

Create a JDK 8 Stream from the supplied Adapter

stream(Publisher<T>) - Static method in class com.aol.cyclops.control.Publishers

Convert a reactive-streams Publisher to a cyclops-react ReactiveSeq extended Stream type

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

stream(Flux<X>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

Create a LazyFluentCollection from a Flux.

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

stream(Flux<X>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

stream() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

stream() - Method in class com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource

Create a pushable JDK 8 Stream

stream() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

stream() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

stream() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

stream() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

subList(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

subList(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

subList(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

subList(int, int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

subscribe(Subscriber<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

subscribeTo(K, Subscriber<V>) - Method in class com.aol.cyclops.control.ReactorPipes

Subscribe synchronously to a pipe

subscribeTo(K, Subscriber<V>, Executor) - Method in class com.aol.cyclops.control.ReactorPipes

Subscribe asynchronously to a pipe

subSet(T, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

T

tailSet(T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

takeRight(int) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

takeRight(int) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

takeRight(int) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

takeRight(int) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

takeUntil(Flux<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Take elements from the Stream until the predicate returns true, after which all elements are excluded.

takeUntil(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

takeUntil(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

takeUntil(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

takeWhile(Predicate<? super T>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

takeWhile(Predicate<? super T>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

takeWhile(Predicate<? super A>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

test(Mono<T>, T) - Static method in class com.aol.cyclops.reactor.Monos

Test if value is equal to the value inside this Mono

test(A) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

toArray() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

toArray(T[]) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

toPStack() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

toPVector() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

toPVector() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

toPVector() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

toPVector() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

toPVector() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

toString() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

toString() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

toString() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

toString() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

toString() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

trampoline(Flux<T>, Function<? super T, ? extends Trampoline<? extends R>>) - Static method in class com.aol.cyclops.reactor.Fluxes

Performs a map operation that can call a recursive method without running out of stack space

trampoline(Function<? super T, ? extends Trampoline<? extends R>>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

trampoline(Function<? super A, ? extends Trampoline<? extends R>>) - Method in interface com.aol.cyclops.reactor.transformer.MonoT

trampoline(Function<? super A, ? extends Trampoline<? extends R>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

transformerStream() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

transformerStream() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

transformerStream() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

U

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

Unfold a function into a ListX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

Unfold a function into a LazyQueueX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

Unfold a function into a LazySetX

unfold(U, Function<? super U, Optional<Tuple2<T, U>>>) - Static method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

Unfold a function into a LazySortedSetX

unit(Collection<R>) - Method in interface com.aol.cyclops.reactor.collections.extensions.base.LazyFluentCollectionX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

unit(Collection<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

unit(R) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

unit(R) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Create an instance of the same FluxTransformer that contains a Flux with just the value provided

unit(T) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

unit(T) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

unit(R) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

unit(R) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

unitAnyM(AnyM<Traversable<T>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

unitAnyM(AnyM<Traversable<T>>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

unitAnyM(AnyM<Traversable<T>>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

unitIterator(Iterator<U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

unitIterator(Iterator<R>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

Create an instance of the same FluxTransformer type from the provided Iterator over raw values.

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

unitIterator(Iterator<U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

unitIterator(Iterator<R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

unitStream(ReactiveSeq<T>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

unwrap() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

unwrap() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

unwrap() - Method in class com.aol.cyclops.reactor.transformer.FluxTValue

unwrap() - Method in interface com.aol.cyclops.reactor.transformer.MonoT

unwrap() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

unwrap() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

unwrapOtherMonadTypes(Comprehender<Flux>, Object) - Static method in class com.aol.cyclops.reactor.comprehenders.FluxComprehender

V

value() - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

visit(BiFunction<? super X, ? super R, ? extends U>) - Method in class com.aol.cyclops.reactor.flux.pushable.AbstractPushablePublisher

W

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

PStackX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

ListX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

ListX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

QueueX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

SetX methods

with(int, T) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

SortedSetX methods

X

xValues(K, long) - Method in class com.aol.cyclops.control.ReactorPipes

Z

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(BiFunction<? super T, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip(Mono<? extends T1>, Iterable<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class com.aol.cyclops.reactor.Monos

Combine the provided Mono with the first element (if present) in the provided Iterable using the provided BiFunction

zip(Mono<? extends T1>, BiFunction<? super T1, ? super T2, ? extends R>, Publisher<? extends T2>) - Static method in class com.aol.cyclops.reactor.Monos

Combine the provided Mono with the first element (if present) in the provided Publisher using the provided BiFunction

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Seq<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Stream<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Stream<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Seq<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Iterable<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip(Iterable<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

zip(Iterable<? extends U>, BiFunction<? super A, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Stream<? extends U>, BiFunction<? super A, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Seq<? extends U>, BiFunction<? super A, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip(Iterable<? extends T2>, BiFunction<? super A, ? super T2, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(BiFunction<? super A, ? super T2, ? extends R>, Publisher<? extends T2>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(Seq<? extends U>, BiFunction<? super A, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(Stream<? extends U>, BiFunction<? super A, ? super U, ? extends R>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(Stream<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(Seq<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip(Iterable<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTValue

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip3(Stream<? extends S>, Stream<? extends U>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

zip3(Stream<? extends S>, Stream<? extends U>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

zip4(Stream<? extends T2>, Stream<? extends T3>, Stream<? extends T4>) - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.base.AbstractFluentCollectionX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPBagX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPOrderedSetX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPQueueX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPSetX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPStackX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.persistent.LazyPVectorX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyDequeX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyListX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazyQueueX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySetX

zipWithIndex() - Method in class com.aol.cyclops.reactor.collections.extensions.standard.LazySortedSetX

zipWithIndex(Flux<T>) - Static method in class com.aol.cyclops.reactor.Fluxes

Add an index to the supplied Flux

zipWithIndex() - Method in interface com.aol.cyclops.reactor.transformer.FluxT

zipWithIndex() - Method in class com.aol.cyclops.reactor.transformer.FluxTSeq

zipWithIndex() - Method in class com.aol.cyclops.reactor.transformer.MonoTSeq

A B C D E F G H I J L M N O P R S T U V W X Z