com.aol.cyclops.javaslang.reactivestreams

Class ReactiveStreamImpl<T>

java.lang.Object

com.aol.cyclops.javaslang.reactivestreams.ReactiveStreamImpl<T>

Type Parameters:

T -

All Implemented Interfaces:

ReactiveStream<T>, com.aol.cyclops.lambda.monads.Functor<T>, com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>, java.io.Serializable, java.lang.Iterable<T>, java.util.function.Function<java.lang.Integer,T>, javaslang.collection.Foldable<T>, LazyStream<T>, javaslang.collection.LinearSeq<T>, javaslang.collection.Seq<T>, javaslang.collection.Stream<T>, javaslang.collection.Traversable<T>, javaslang.Function1<java.lang.Integer,T>, javaslang.Value<T>, javaslang.λ<T>, org.reactivestreams.Publisher<T>

public class ReactiveStreamImpl<T>
extends java.lang.Object
implements ReactiveStream<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface javaslang.collection.LazyStream

LazyStream.Empty<T>, LazyStream.LazyCons<T>

Nested classes/interfaces inherited from interface javaslang.collection.Stream

javaslang.collection.Stream.Cons<T>

Nested classes/interfaces inherited from interface javaslang.Function1

javaslang.Function1.Type<T1,R>

Nested classes/interfaces inherited from interface javaslang.λ

javaslang.λ.Memoized

Field Summary

Fields inherited from interface javaslang.collection.LazyStream

serialVersionUID

Method Summary

Modifier and Type	Method and Description
ReactiveStream<T>	appendSelf(java.util.function.Function<? super javaslang.collection.Stream<T>,? extends javaslang.collection.Stream<T>> mapper) Appends itself to the end of stream with mapper function.
boolean	equals(java.lang.Object obj)
<R1,R> ReactiveStream<R>	forEach2(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1, java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends R>> yieldingFunction) Perform a two level nested internal iteration over this Stream and the supplied stream
<R1,R> ReactiveStream<R>	forEach2(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1, java.util.function.Function<? super T,java.util.function.Function<? super R1,java.lang.Boolean>> filterFunction, java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends R>> yieldingFunction) Perform a two level nested internal iteration over this Stream and the supplied stream
<R1,R2,R> ReactiveStream<R>	forEach3(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1, java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends java.lang.Iterable<R2>>> stream2, java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,? extends R>>> yieldingFunction) Perform a three level nested internal iteration over this Stream and the supplied streams
<R1,R2,R> ReactiveStream<R>	forEach3(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1, java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends java.lang.Iterable<R2>>> stream2, java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,java.lang.Boolean>>> filterFunction, java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,? extends R>>> yieldingFunction) Perform a three level nested internal iteration over this Stream and the supplied streams
<X extends java.lang.Throwable> void	forEachEvent(java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError, java.lang.Runnable onComplete)
<X extends java.lang.Throwable> void	forEachWithError(java.util.function.Consumer<? super T> consumerElement, java.util.function.Consumer<? super java.lang.Throwable> consumerError)
<X extends java.lang.Throwable> org.reactivestreams.Subscription	forEachX(long numberOfElements, java.util.function.Consumer<? super T> consumer)
<X extends java.lang.Throwable> org.reactivestreams.Subscription	forEachXEvents(long numberOfElements, java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> consumerError, java.lang.Runnable onComplete)
<X extends java.lang.Throwable> org.reactivestreams.Subscription	forEachXWithError(long numberOfElements, java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> consumerError)
int	hashCode()
T	head()
boolean	isEmpty()
java.util.function.Supplier<T>	lazyHead()
java.util.stream.Stream<T>	parallel()
LazyStream<T>	toStream()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aol.cyclops.javaslang.reactivestreams.ReactiveStream

append, append, appendAll, asyncMap, asyncRetry, cast, clear, combinations, combinations, cons, crossProduct, crossProduct, crossProduct, cycle, cycle, cycleUntil, cycleWhile, debounce, distinct, distinctBy, distinctBy, drop, drop, dropRight, dropWhile, elapsed, empty, filter, fixedDelay, flatMap, flatten, foldRight, foldRight2, from, from, fromAnyM, fromAsyncQueue, fromIterable, fromIterator, fromJDK, fromStream, fromStreamable, futureOperations, generate, groupByReactive, hotStream, init, initOptionReactive, insert, insertAll, intersperse, iterate, iterator, jitter, map, mapReduce, mapReduce, of, ofType, onEmpty, onEmptyGet, onEmptySwitch, onEmptyThrow, onePer, padTo, partitionReactive, patch, pausedHotStream, peek, permutations, prepend, prepend, prependAll, range, range, recover, recover, reduce, reduce, remove, removeAll, removeAll, removeAt, removeBetween, removeFirst, removeLast, replace, replaceAll, retainAll, retry, reverse, scanLeft, scanLeft, scanRight, scanRight, schedule, scheduleFixedDelay, scheduleFixedRate, single, single, singleOption, slice, slidingWindow, slidingWindow, sort, sort, sortBy, sortBy, spanReactive, splitAtInclusiveReactive, splitAtReactive, splitAtReactive, subscribe, subscribeAsync, subscriber, subSequence, subSequence, subStream, tail, tailOptionReactive, take, take, takeRight, takeUntil, takeWhile, timestamp, trampoline, unit, unzip3Reactive, unzipReactive, update, windowBySize, windowBySizeAndTime, windowByTime, windowStatefullyWhile, windowUntil, windowWhile, xMatch, xPer, zip, zipAll, zipAnyM, zipWithIndex

Methods inherited from interface javaslang.collection.LazyStream

anyM, collect, collect, collectable, collector, dropUntil, fill, futures, futures, futureStream, futureStream, gen, gen, get, groupBy, grouped, hasDefiniteSize, headOption, indexOf, initOption, isTraversableAgain, lastIndexOf, length, match, ofAll, ofAll, ofAll, ofAll, ofAll, ofAll, ofAll, ofAll, ofAll, partition, range, rangeBy, rangeBy, rangeBy, rangeBy, rangeClosed, rangeClosed, rangeClosed, rangeClosedBy, rangeClosedBy, rangeClosedBy, rangeClosedBy, repeat, scan, seq, sequenceM, sliding, sliding, span, splitAt, splitAt, splitAtInclusive, spliterator, stream, streamable, stringPrefix, tabulate, tailOption, toAsyncBlockingQueue, toAsyncQueue, toAsyncQueue, toCollection, toTraversable, unzip, unzip3

Methods inherited from interface javaslang.collection.Stream

cons

Methods inherited from interface javaslang.collection.LinearSeq

indexWhere, lastIndexOfSlice, lastIndexWhere, reverseIterator, segmentLength

Methods inherited from interface javaslang.collection.Seq

apply, containsSlice, endsWith, foldRight, indexOf, indexOfSlice, indexOfSlice, indexWhere, iterator, lastIndexOf, lastIndexOfSlice, lastIndexWhere, prefixLength, startsWith, startsWith, transform

Methods inherited from interface javaslang.collection.Traversable

average, containsAll, count, existsUnique, find, findLast, foldLeft, get, hash, isSingleValued, last, lastOption, max, maxBy, maxBy, min, minBy, minBy, mkString, mkString, mkString, product, reduceLeft, reduceLeftOption, reduceRight, reduceRightOption, size, sum

Methods inherited from interface javaslang.collection.Foldable

fold, reduce, reduceOption

Methods inherited from interface javaslang.Value

contains, corresponds, eq, exists, forAll, forEach, getOption, getOrElse, getOrElse, getOrElseThrow, getOrElseTry, isDefined, out, out, stderr, stdout, toArray, toCharSeq, toJavaArray, toJavaArray, toJavaList, toJavaMap, toJavaOptional, toJavaSet, toJavaStream, toLeft, toLeft, toList, toMap, toOption, toQueue, toRight, toRight, toSet, toStack, toTree, toTry, toTry, toVector

Methods inherited from interface javaslang.Function1

andThen, arity, compose, curried, getType, identity, lift, memoized, reversed, tupled

Methods inherited from interface javaslang.λ

isApplicableTo, isApplicableToTypes, isMemoized

Method Detail

toString

public java.lang.String toString()

Specified by:

toString in interface javaslang.Value<T>

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Specified by:

hashCode in interface javaslang.Value<T>

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Specified by:

equals in interface javaslang.Value<T>

Overrides:

equals in class java.lang.Object

appendSelf

public ReactiveStream<T> appendSelf(java.util.function.Function<? super javaslang.collection.Stream<T>,? extends javaslang.collection.Stream<T>> mapper)

Description copied from interface: LazyStream

Appends itself to the end of stream with mapper function.

Example:

Well known scala code for Fibonacci infinite sequence

 
 val fibs:Stream[Int] = 0 #:: 1 #:: (fibs zip fibs.tail).map{ t => t._1 + t._2 }
 
 

can be transformed to

 
 Stream.of(0, 1).appendSelf(self -> self.zip(self.tail()).map(t -> t._1 + t._2));
 
 

Specified by:

appendSelf in interface LazyStream<T>

Specified by:

appendSelf in interface javaslang.collection.Stream<T>

Parameters:

mapper - an mapper

Returns:

a new Stream

parallel

public java.util.stream.Stream<T> parallel()

toStream

public LazyStream<T> toStream()

Specified by:

toStream in interface LazyStream<T>

Specified by:

toStream in interface javaslang.Value<T>

forEachX

public <X extends java.lang.Throwable> org.reactivestreams.Subscription forEachX(long numberOfElements,
                                                                                 java.util.function.Consumer<? super T> consumer)

Specified by:

forEachX in interface com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>

forEachXWithError

public <X extends java.lang.Throwable> org.reactivestreams.Subscription forEachXWithError(long numberOfElements,
                                                                                          java.util.function.Consumer<? super T> consumer,
                                                                                          java.util.function.Consumer<? super java.lang.Throwable> consumerError)

Specified by:

forEachXWithError in interface com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>

forEachXEvents

public <X extends java.lang.Throwable> org.reactivestreams.Subscription forEachXEvents(long numberOfElements,
                                                                                       java.util.function.Consumer<? super T> consumer,
                                                                                       java.util.function.Consumer<? super java.lang.Throwable> consumerError,
                                                                                       java.lang.Runnable onComplete)

Specified by:

forEachXEvents in interface com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>

forEachWithError

public <X extends java.lang.Throwable> void forEachWithError(java.util.function.Consumer<? super T> consumerElement,
                                                             java.util.function.Consumer<? super java.lang.Throwable> consumerError)

Specified by:

forEachWithError in interface com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>

forEachEvent

public <X extends java.lang.Throwable> void forEachEvent(java.util.function.Consumer<? super T> consumerElement,
                                                         java.util.function.Consumer<? super java.lang.Throwable> consumerError,
                                                         java.lang.Runnable onComplete)

Specified by:

forEachEvent in interface com.aol.cyclops.sequence.reactivestreams.ReactiveStreamsTerminalOperations<T>

forEach3

public <R1,R2,R> ReactiveStream<R> forEach3(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1,
                                            java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends java.lang.Iterable<R2>>> stream2,
                                            java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,? extends R>>> yieldingFunction)

Description copied from interface: ReactiveStream

Perform a three level nested internal iteration over this Stream and the supplied streams

  
 SequenceM.of(1,2)
 						.forEach3(a->IntStream.range(10,13),
 						        a->b->Stream.of(""+(a+b),"hello world"),
 									a->b->c->c+":"a+":"+b);
 									
 
  //SequenceM[11:1:2,hello world:1:2,14:1:4,hello world:1:4,12:1:2,hello world:1:2,15:1:5,hello world:1:5]
 
 

Specified by:

forEach3 in interface ReactiveStream<T>

Parameters:

stream1 - Nested Stream to iterate over

stream2 - Nested Stream to iterate over

yieldingFunction - Function with pointers to the current element from both Streams that generates the new elements

Returns:

SequenceM with elements generated via nested iteration

forEach3

public <R1,R2,R> ReactiveStream<R> forEach3(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1,
                                            java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends java.lang.Iterable<R2>>> stream2,
                                            java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,java.lang.Boolean>>> filterFunction,
                                            java.util.function.Function<? super T,java.util.function.Function<? super R1,java.util.function.Function<? super R2,? extends R>>> yieldingFunction)

Description copied from interface: ReactiveStream

Perform a three level nested internal iteration over this Stream and the supplied streams

  
 SequenceM.of(1,2,3)
 						.forEach3(a->IntStream.range(10,13),
 						      a->b->Stream.of(""+(a+b),"hello world"),
 						         a->b->c-> c!=3,
 									a->b->c->c+":"a+":"+b);
 									
 
  //SequenceM[11:1:2,hello world:1:2,14:1:4,hello world:1:4,12:1:2,hello world:1:2,15:1:5,hello world:1:5]
 
 

Specified by:

forEach3 in interface ReactiveStream<T>

Parameters:

stream1 - Nested Stream to iterate over

stream2 - Nested Stream to iterate over

filterFunction - Filter to apply over elements before passing non-filtered values to the yielding function

yieldingFunction - Function with pointers to the current element from both Streams that generates the new elements

Returns:

SequenceM with elements generated via nested iteration

forEach2

public <R1,R> ReactiveStream<R> forEach2(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1,
                                         java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends R>> yieldingFunction)

Description copied from interface: ReactiveStream

Perform a two level nested internal iteration over this Stream and the supplied stream

  
 SequenceM.of(1,2,3)
 						.forEach2(a->IntStream.range(10,13),
 									a->b->a+b);
 									
 
  //SequenceM[11,14,12,15,13,16]
 
 

Specified by:

forEach2 in interface ReactiveStream<T>

Parameters:

stream1 - Nested Stream to iterate over

yieldingFunction - Function with pointers to the current element from both Streams that generates the new elements

Returns:

SequenceM with elements generated via nested iteration

forEach2

public <R1,R> ReactiveStream<R> forEach2(java.util.function.Function<? super T,? extends java.lang.Iterable<R1>> stream1,
                                         java.util.function.Function<? super T,java.util.function.Function<? super R1,java.lang.Boolean>> filterFunction,
                                         java.util.function.Function<? super T,java.util.function.Function<? super R1,? extends R>> yieldingFunction)

Description copied from interface: ReactiveStream

Perform a two level nested internal iteration over this Stream and the supplied stream

  
 SequenceM.of(1,2,3)
 						.forEach2(a->IntStream.range(10,13),
 						            a->b-> a<3 && b>10,
 									a->b->a+b);
 									
 
  //SequenceM[14,15]
 
 

Specified by:

forEach2 in interface ReactiveStream<T>

Parameters:

stream1 - Nested Stream to iterate over

filterFunction - Filter to apply over elements before passing non-filtered values to the yielding function

yieldingFunction - Function with pointers to the current element from both Streams that generates the new elements

Returns:

SequenceM with elements generated via nested iteration

head

public T head()

Specified by:

head in interface javaslang.collection.Traversable<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface javaslang.collection.Traversable<T>

Specified by:

isEmpty in interface javaslang.Value<T>

lazyHead

public java.util.function.Supplier<T> lazyHead()

Specified by:

lazyHead in interface LazyStream<T>