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

Class Concat<IN>

java.lang.Object

com.aol.cyclops2.internal.stream.spliterators.push.Concat<IN>

public class Concat<IN>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Concat(StreamSubscription sub, ListX<Operator<IN>> operators, java.util.function.Consumer<? super IN> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)

Method Summary

Modifier and Type	Method and Description
void	addMissingRequests()
void	cancel()
void	emitted(long n)
void	onComplete()
void	onError(java.lang.Throwable t)
void	onNext(IN e)
void	request(long n)
boolean	subscribeNext()

Methods inherited from class java.lang.Object

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

Constructor Detail

Concat

public Concat(StreamSubscription sub,
              ListX<Operator<IN>> operators,
              java.util.function.Consumer<? super IN> onNext,
              java.util.function.Consumer<? super java.lang.Throwable> onError,
              java.lang.Runnable onComplete)

Method Detail

request

public void request(long n)

addMissingRequests

public void addMissingRequests()

emitted

public void emitted(long n)

onError

public void onError(java.lang.Throwable t)

onNext

public void onNext(IN e)

onComplete

public void onComplete()

subscribeNext

public boolean subscribeNext()

cancel

public void cancel()