- cast(Class<U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Cast all elements in a stream to a given type, possibly throwing a
ClassCastException.
- cast(Stream<T>, Class<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Cast all elements in a stream to a given type, possibly throwing a
ClassCastException.
- characteristics() - Method in class com.aol.cyclops.streams.spliterators.ClosingSpliterator
-
- close() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- ClosingSpliterator<T> - Class in com.aol.cyclops.streams.spliterators
-
- ClosingSpliterator(long, Queue, AtomicBoolean) - Constructor for class com.aol.cyclops.streams.spliterators.ClosingSpliterator
-
- collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Mutable reduction / collection over this Monad converted to a Stream
- collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- collect(Stream<Collector>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Apply multiple collectors Simulataneously to this Monad
- collect(Collector<? super T, A, R>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously perform a Stream collection
- collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously perform a Stream collection
- collect(Streamable<Collector>) - Method in class com.aol.cyclops.streams.operators.MultiCollectOperator
-
- collect(Stream<T>, Stream<Collector>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Apply multiple Collectors, simultaneously to a Stream
- collect(Stream<T>, Iterable<Collector>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Apply multiple Collectors, simultaneously to a Stream
- collect(Stream<T>, Streamable<Collector>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Apply multiple Collectors, simultaneously to a Stream
- collectIterable(Iterable<Collector>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Apply multiple Collectors, simultaneously to a Stream
- collectStream(Stream<Collector>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- com.aol.cyclops.sequence - package com.aol.cyclops.sequence
-
- com.aol.cyclops.streams - package com.aol.cyclops.streams
-
- com.aol.cyclops.streams.future - package com.aol.cyclops.streams.future
-
- com.aol.cyclops.streams.operators - package com.aol.cyclops.streams.operators
-
- com.aol.cyclops.streams.spliterators - package com.aol.cyclops.streams.spliterators
-
- completableFutureToStream(CompletableFuture<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- concat(Stream<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- concat(T) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- concat(T...) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- concat(Object, Stream<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Concat an Object and a Stream
If the Object is a Stream, Streamable or Iterable will be converted (or left) in Stream form and concatonated
Otherwise a new Stream.of(o) is created
- connect() - Method in class com.aol.cyclops.streams.HotStreamImpl
-
- connect(Queue<T>) - Method in class com.aol.cyclops.streams.HotStreamImpl
-
- connectTo(Queue<T>, Function<SequenceM<T>, R>) - Method in class com.aol.cyclops.streams.HotStreamImpl
-
- count() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- count() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously perform a Stream count
- crossJoin(Stream<U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- cycle(int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Convert to a Stream with the values repeated specified times
- cycle() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Convert to a Stream with the values infinitely cycled
- cycle(Monoid<T>, int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Convert to a Stream with the result of a reduction operation repeated
specified times
- cycle(Class<R>, int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Convert to a Stream, repeating the resulting structure specified times
and lifting all values to the specified Monad type
- cycle(Stream<T>, Monoid<T>, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Convert to a Stream with the result of a reduction operation repeated
specified times
- cycle(Stream<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a new Stream that infiniteable cycles the provided Stream
- cycle(Streamable<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a Stream that infiniteable cycles the provided Streamable
- cycle(int, Streamable<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a Stream that finitely cycles the provided Streamable, provided number of times
- cycleUntil(Predicate<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Repeat in a Stream until specified predicate holds
- cycleUntil(Stream<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Repeat in a Stream until specified predicate holds
- cycleWhile(Predicate<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Repeat in a Stream while specified predicate holds
- cycleWhile(Stream<T>, Predicate<? super T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Repeat in a Stream while specified predicate holds
- filter(Predicate<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- findAny() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- findAny() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asynchronous findAny operation
- findFirst() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- findFirst() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asynchronous findAny operation
- firstValue() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- firstValue() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asynchronous findAny operation
- firstValue(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- fixedDelay(long, TimeUnit) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- fixedDelay(Stream<T>, long, TimeUnit) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- flatMap(Function<? super T, ? extends Stream<? extends R>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
flatMap operation
- flatMapAnyM(Function<? super T, AnyM<? extends R>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Allows flatMap return type to be any Monad type
- flatMapAnyM(Stream<T>, Function<? super T, AnyM<? extends R>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- flatMapBufferedReader(Function<? super T, BufferedReader>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied BufferedReaders
- flatMapBufferedReader(Stream<T>, Function<? super T, BufferedReader>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied BufferedReaders
- flatMapCharSequence(Function<? super T, CharSequence>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Perform a flatMap operation where the result will be a flattened stream of Characters
from the CharSequence returned by the supplied function.
- flatMapCharSequence(Stream<T>, Function<? super T, CharSequence>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Perform a flatMap operation where the result will be a flattened stream of Characters
from the CharSequence returned by the supplied function.
- flatMapCollection(Function<? super T, Collection<? extends R>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Convenience method & performance optimisation
flatMapping to a Stream will result in the Stream being converted to a List, if the host Monad
type is not a Stream.
- flatMapCollection(Stream<T>, Function<? super T, Collection<? extends R>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
flatMap operation that allows a Collection to be returned
- flatMapCompletableFuture(Function<? super T, CompletableFuture<? extends R>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
flatMap to CompletableFuture - will block until Future complete, although (for non-blocking behaviour use AnyM
wrapping CompletableFuture and flatMap to Stream there)
- flatMapCompletableFuture(Stream<T>, Function<? super T, CompletableFuture<? extends R>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
assertThat(StreamUtils.flatMapCompletableFuture(Stream.of(1,2,3),
i->CompletableFuture.completedFuture(i+2))
.collect(Collectors.toList()),
equalTo(Arrays.asList(3,4,5)));
- flatMapFile(Function<? super T, File>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied files.
- flatMapFile(Stream<T>, Function<? super T, File>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied files.
- flatMapOptional(Function<? super T, Optional<? extends R>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
flatMap to optional - will result in null values being removed
- flatMapOptional(Stream<T>, Function<? super T, Optional<? extends R>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
cross type flatMap, removes null entries
- flatMapSequenceM(Stream<T>, Function<? super T, SequenceM<? extends R>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
flatMap operation
- flatMapStream(Function<? super T, BaseStream<? extends R, ?>>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
flatMap operation
- flatMapStream(Stream<T>, Function<? super T, BaseStream<? extends R, ?>>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
assertThat(StreamUtils.flatMapStream(Stream.of(1,2,3),
i->Stream.of(i)).collect(Collectors.toList()),
equalTo(Arrays.asList(1,2,3)));
- flatMapToDouble(Function<? super T, ? extends DoubleStream>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- flatMapToInt(Function<? super T, ? extends IntStream>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- flatMapToLong(Function<? super T, ? extends LongStream>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- flatMapURL(Function<? super T, URL>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied URLs
- flatMapURL(Stream<T>, Function<? super T, URL>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Perform a flatMap operation where the result will be a flattened stream of Strings
from the text loaded from the supplied URLs
- flatten() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
join / flatten one level of a nested hierarchy
- flatten(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- foldLeft(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- foldLeft(T, BinaryOperator<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
foldLeft : immutable reduction from left to right
- foldLeft(U, BiFunction<U, ? super T, U>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asynchronous foldLeft operation
- foldLeft(Stream<T>, Monoid<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- foldLeftMapToType(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- foldLeftMapToType(Stream<T>, Monoid<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- foldRight(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- foldRight(U, BiFunction<? super T, U, U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Immutable reduction from right to left
- foldRight(T, BinaryOperator<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- foldRight(U, BiFunction<? super T, U, U>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asynchronous foldRight operation
- foldRight(Stream<T>, Monoid<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- foldRightMapToType(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- foldRightMapToType(Stream<T>, Monoid<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- forEach(Consumer<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- forEach(Consumer<T>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
- forEachOrdered(Consumer<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- futureOperations(Executor) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- futureOperations(Stream<T>, Executor) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- FutureOperationsImpl<T> - Class in com.aol.cyclops.streams.future
-
- FutureOperationsImpl() - Constructor for class com.aol.cyclops.streams.future.FutureOperationsImpl
-
- map(Function<? super T, ? extends R>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- mapReduce(Monoid<R>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- mapReduce(Function<? super T, ? extends R>, Monoid<R>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Attempt to map this Monad to the same type as the supplied Monoid, using supplied function
Then use Monoid to reduce values
- mapReduce(Stream<T>, Monoid<R>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Attempt to map this Monad to the same type as the supplied Monoid (using mapToType on the monoid interface)
Then use Monoid to reduce values
- mapReduce(Stream<T>, Function<? super T, ? extends R>, Monoid<R>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Attempt to map this Monad to the same type as the supplied Monoid, using supplied function
Then use Monoid to reduce values
- mapToDouble(ToDoubleFunction<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- mapToInt(ToIntFunction<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- mapToLong(ToLongFunction<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- max(Comparator<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- max(Comparator<? super T>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asyncrhonous min operation
- max(Stream<T>, Comparator<? super T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- maxBy(Function<T, C>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Extract the maximum as determined by the supplied function
- maxBy(Function<T, U>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously capture the maximum value in this stream using the provided function
- maxBy(Stream<T>, Function<T, C>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- maxDouble(ToDoubleFunction<T>) - Method in interface com.aol.cyclops.streams.future.DoubleOperatorsMixin
-
Perform an asynchronous max operation
- maxInt(ToIntFunction<T>) - Method in interface com.aol.cyclops.streams.future.IntOperatorsMixin
-
Perform an asynchronous max operation
- maxLong(ToLongFunction<T>) - Method in interface com.aol.cyclops.streams.future.LongOperatorsMixin
-
Perform an asynchronous max operation
- min(Comparator<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- min(Comparator<? super T>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Perform an asyncrhonous min operation
- min(Stream<T>, Comparator<? super T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- minBy(Function<T, U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Extract the minimum as determined by supplied function
- minBy(Function<T, U>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously capture the minimum value in this stream using the provided function
- minBy(Stream<T>, Function<T, C>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- minDouble(ToDoubleFunction<T>) - Method in interface com.aol.cyclops.streams.future.DoubleOperatorsMixin
-
Perform an asynchronous min operation
- minInt(ToIntFunction<T>) - Method in interface com.aol.cyclops.streams.future.IntOperatorsMixin
-
Perform an asynchronous min operation
- minLong(ToLongFunction<T>) - Method in interface com.aol.cyclops.streams.future.LongOperatorsMixin
-
Perform an asynchronous min operation
- MultiCollectOperator<T> - Class in com.aol.cyclops.streams.operators
-
- MultiCollectOperator() - Constructor for class com.aol.cyclops.streams.operators.MultiCollectOperator
-
- MultiReduceOperator<R> - Class in com.aol.cyclops.streams.operators
-
- MultiReduceOperator() - Constructor for class com.aol.cyclops.streams.operators.MultiReduceOperator
-
- scanLeft(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Scan left using supplied Monoid
- scanLeft(U, BiFunction<U, ? super T, U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Scan left
- scanLeft(Stream<T>, Monoid<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Scan left using supplied Monoid
- scanRight(Monoid<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Scan right
- scanRight(U, BiFunction<? super T, U, U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Scan right
- scanRight(Stream<T>, U, BiFunction<? super T, U, U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- sequenceM(Stream<T>, ReversableSpliterator) - Method in class com.aol.cyclops.sequence.SequenceMFactoryImpl
-
- sequenceM(Stream<T>, Optional<ReversableSpliterator>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- SequenceMFactoryImpl - Class in com.aol.cyclops.sequence
-
- SequenceMFactoryImpl() - Constructor for class com.aol.cyclops.sequence.SequenceMFactoryImpl
-
- SequenceMImpl<T> - Class in com.aol.cyclops.sequence
-
- SequenceMImpl(Stream<T>) - Constructor for class com.aol.cyclops.sequence.SequenceMImpl
-
- SequenceMImpl(Stream<T>, ReversableSpliterator) - Constructor for class com.aol.cyclops.sequence.SequenceMImpl
-
- sequential() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- shuffle() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- shuffle(Random) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- shuffle(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- single() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
- skip(long) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertThat(anyM(Stream.of(4,3,6,7)).asSequence().skip(2).toList(),equalTo(Arrays.asList(6,7)));
- skip(long, TimeUnit) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- skip(Stream<U>, long, TimeUnit) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- skipLast(int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- skipLast() - Method in class com.aol.cyclops.streams.operators.SkipLastOperator
-
- skipLast(Stream<U>, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- SkipLastOperator<T> - Class in com.aol.cyclops.streams.operators
-
- SkipLastOperator(Stream<T>, int) - Constructor for class com.aol.cyclops.streams.operators.SkipLastOperator
-
- skipUntil(Predicate<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertThat(anyM(Stream.of(4,3,6,7)).asSequence().skipUntil(i->i==6).toList(),equalTo(Arrays.asList(6,7)));
- skipUntil(Stream<U>, Predicate<? super U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
skip elements in Stream until Predicate holds true
- skipWhile(Predicate<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertThat(anyM(Stream.of(4,3,6,7)).asSequence().sorted().skipWhile(i->i<6).toList(),equalTo(Arrays.asList(6,7)));
- skipWhile(Predicate<? super U>) - Method in class com.aol.cyclops.streams.operators.SkipWhileOperator
-
- skipWhile(long, TimeUnit) - Method in class com.aol.cyclops.streams.operators.SkipWhileTimeOperator
-
- skipWhile(Stream<U>, Predicate<? super U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
skip elements in a Stream while Predicate holds true
- SkipWhileOperator<U> - Class in com.aol.cyclops.streams.operators
-
- SkipWhileOperator() - Constructor for class com.aol.cyclops.streams.operators.SkipWhileOperator
-
- SkipWhileTimeOperator<U> - Class in com.aol.cyclops.streams.operators
-
- SkipWhileTimeOperator() - Constructor for class com.aol.cyclops.streams.operators.SkipWhileTimeOperator
-
- slice(long, long) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- sliding(int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Create a sliding view over this Sequence
- sliding(int, int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Create a sliding view over this Sequence
- sliding(Stream<T>, int, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a sliding view over this Stream
- sliding(Stream<T>, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a sliding view over this Stream
- sorted() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertThat(SequenceM.of(4,3,6,7)).sorted().toList(),equalTo(Arrays.asList(3,4,6,7)));
- sorted(Comparator<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertThat(anyM(Stream.of(4,3,6,7)).asSequence().sorted((a,b) -> b-a).toList(),equalTo(Arrays.asList(7,6,4,3)));
- sorted(Function<? super T, ? extends U>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- splitAt(int) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Split at supplied location
- splitAt(Stream<T>, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Split at supplied location
- splitBy(Predicate<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Split stream at point where predicate no longer holds
- splitBy(Stream<T>, Predicate<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Split stream at point where predicate no longer holds
- spliterator() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- splitSequenceAtHead() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Split a Stream at it's head (similar to headAndTail)
- startsWith(Iterable<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertTrue(StreamUtils.sequenceM(Stream.of(1,2,3,4)).startsWith(Arrays.asList(1,2,3)));
- startsWith(Iterator<T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
assertTrue(StreamUtils.sequenceM(Stream.of(1,2,3,4)).startsWith(Arrays.asList(1,2,3).iterator()))
- startsWith(Stream<T>, Iterable<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
assertTrue(StreamUtils.startsWith(Stream.of(1,2,3,4),Arrays.asList(1,2,3)));
- startsWith(Stream<T>, Iterator<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
assertTrue(StreamUtils.startsWith(Stream.of(1,2,3,4),Arrays.asList(1,2,3).iterator()))
- stream() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Unwrap this Monad into a Stream.
- stream(Iterable<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a stream from an iterable
- stream(Spliterator<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- stream(Iterator<U>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a stream from an iterator
- stream(Map<K, V>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Create a stream from a map
- streamToCompletableFuture(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- streamToOptional(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- StreamUtils - Class in com.aol.cyclops.streams
-
- StreamUtils() - Constructor for class com.aol.cyclops.streams.StreamUtils
-
- subscribe(Subscriber<? super T>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- sumDouble(ToDoubleFunction<T>) - Method in interface com.aol.cyclops.streams.future.DoubleOperatorsMixin
-
Perform an asynchronous sum operation
- sumInt(ToIntFunction<T>) - Method in interface com.aol.cyclops.streams.future.IntOperatorsMixin
-
Perform an asynchronous sum operation
- sumLong(ToLongFunction<T>) - Method in interface com.aol.cyclops.streams.future.LongOperatorsMixin
-
Perform an asynchronous sum operation
- summaryStatisticsDouble(ToDoubleFunction<T>) - Method in interface com.aol.cyclops.streams.future.DoubleOperatorsMixin
-
Perform an asynchronous summaryStatistics operation
- summaryStatisticsInt(ToIntFunction<T>) - Method in interface com.aol.cyclops.streams.future.IntOperatorsMixin
-
Perform an asynchronous summaryStatistics operation
- summaryStatisticsLong(ToLongFunction<T>) - Method in interface com.aol.cyclops.streams.future.LongOperatorsMixin
-
Perform an asynchronous summaryStatistics operation
- toArray() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toArray(IntFunction<A[]>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toArray(IntFunction<A[]>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asyncrhonously generate an Array
- toArray() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asyncrhonously generate an Array
- toBufferingCopier(Iterator<A>, int) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toBufferingDuplicator(Iterator<A>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toBufferingDuplicator(Iterator<A>, long) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toCollection(Supplier<C>) - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toCollection(Supplier<C>) - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously perform a Stream collection
- toCompletableFuture() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
CompletableFuture<List<String>> cf = anyM("hello","world")
.asSequence()
.unwrapCompletableFuture();
assertThat(cf.join(),equalTo(Arrays.asList("hello","world")));
- toConcurrentLazyCollection() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Lazily converts this SequenceM into a Collection.
- toConcurrentLazyCollection(Stream<A>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Lazily constructs a Collection from specified Stream.
- toConcurrentLazyCollection(Iterator<A>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toConcurrentLazyCollection(Stream<A>) - Static method in class com.aol.cyclops.streams.ToLazyCollection
-
Lazily constructs a Collection from specified Stream.
- toConcurrentLazyCollection(Iterator<A>) - Static method in class com.aol.cyclops.streams.ToLazyCollection
-
- toConcurrentLazyStreamable() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toConcurrentLazyStreamable(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toLazyCollection() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Lazily converts this SequenceM into a Collection.
- toLazyCollection(Stream<A>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Projects an immutable collection of this stream.
- toLazyCollection(Iterator<A>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- ToLazyCollection - Class in com.aol.cyclops.streams
-
- ToLazyCollection() - Constructor for class com.aol.cyclops.streams.ToLazyCollection
-
- toLazyCollection(Stream<A>) - Static method in class com.aol.cyclops.streams.ToLazyCollection
-
Projects an immutable collection of this stream.
- toLazyCollection(Iterator<A>) - Static method in class com.aol.cyclops.streams.ToLazyCollection
-
- toLazyStreamable() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toLazyStreamable(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toList() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toList() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously convert this Stream into a List
- toList(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toOptional() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Type safe unwrap
- toSet() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toSet() - Method in class com.aol.cyclops.streams.future.FutureOperationsImpl
-
Asynchronously convert this Stream into a List
- toSet(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- toStream() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toStreamable() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
- toStreamable(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
- triplicate() - Method in class com.aol.cyclops.sequence.SequenceMImpl
-
Triplicates a Stream
Buffers intermediate values, leaders may change positions so a limit
can be safely applied to the leading stream.
- triplicate(Stream<T>) - Static method in class com.aol.cyclops.streams.StreamUtils
-
Triplicates a Stream
Buffers intermediate values, leaders may change positions so a limit
can be safely applied to the leading stream.
- tryAdvance(Consumer<? super T>) - Method in class com.aol.cyclops.streams.spliterators.ClosingSpliterator
-
- trySplit() - Method in class com.aol.cyclops.streams.spliterators.ClosingSpliterator
-