com.aol.cyclops2.internal.stream.spliterators.push

Class ConcurrentFlatMapper<T,R>

java.lang.Object

com.aol.cyclops2.internal.stream.spliterators.push.ConcurrentFlatMapper<T,R>

public class ConcurrentFlatMapper<T,R>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ConcurrentFlatMapper(StreamSubscription s, java.util.function.Consumer<? super R> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(T t)
void	request(long n)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConcurrentFlatMapper

public ConcurrentFlatMapper(StreamSubscription s,
                            java.util.function.Consumer<? super R> onNext,
                            java.util.function.Consumer<? super java.lang.Throwable> onError,
                            java.lang.Runnable onComplete,
                            java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
                            int maxConcurrency)

Method Detail

request

public void request(long n)

onNext

public void onNext(T t)

onError

public void onError(java.lang.Throwable t)

onComplete

public void onComplete()