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

Class CapturingOperator<T>

java.lang.Object

com.aol.cyclops2.internal.stream.spliterators.push.CapturingOperator<T>

All Implemented Interfaces:

Operator<T>

public class CapturingOperator<T>
extends java.lang.Object
implements Operator<T>

Constructor Summary

Constructors

Constructor and Description
CapturingOperator()
CapturingOperator(java.lang.Runnable onInit)
CapturingOperator(org.reactivestreams.Subscription s)

Method Summary

Modifier and Type	Method and Description
void	complete()
boolean	isInitialized()
void	setSubscription(org.reactivestreams.Subscription s)
StreamSubscription	subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
void	subscribeAll(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)

Methods inherited from class java.lang.Object

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

Constructor Detail

CapturingOperator

public CapturingOperator(org.reactivestreams.Subscription s)

CapturingOperator

public CapturingOperator(java.lang.Runnable onInit)

CapturingOperator

public CapturingOperator()

Method Detail

setSubscription

public void setSubscription(org.reactivestreams.Subscription s)

subscribe

public StreamSubscription subscribe(java.util.function.Consumer<? super T> onNext,
                                    java.util.function.Consumer<? super java.lang.Throwable> onError,
                                    java.lang.Runnable onComplete)

Specified by:

subscribe in interface Operator<T>

subscribeAll

public void subscribeAll(java.util.function.Consumer<? super T> onNext,
                         java.util.function.Consumer<? super java.lang.Throwable> onError,
                         java.lang.Runnable onComplete)

Specified by:

subscribeAll in interface Operator<T>

isInitialized

public boolean isInitialized()

complete

public void complete()