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

Class RangeLongOperator

java.lang.Object

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

All Implemented Interfaces:

Operator<java.lang.Long>

public class RangeLongOperator
extends java.lang.Object
implements Operator<java.lang.Long>

Created by johnmcclean on 12/01/2017.

Constructor Summary

Constructors

Constructor and Description
RangeLongOperator(long start, long end)

Method Summary

Modifier and Type	Method and Description
StreamSubscription	subscribe(java.util.function.Consumer<? super java.lang.Long> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete)
void	subscribeAll(java.util.function.Consumer<? super java.lang.Long> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onCompleteDs)

Methods inherited from class java.lang.Object

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

Constructor Detail

RangeLongOperator

public RangeLongOperator(long start,
                         long end)

Method Detail

subscribe

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

Specified by:

subscribe in interface Operator<java.lang.Long>

subscribeAll

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

Specified by:

subscribeAll in interface Operator<java.lang.Long>