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

Class StreamSubscription

java.lang.Object

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

All Implemented Interfaces:

org.reactivestreams.Subscription

public class StreamSubscription
extends java.lang.Object
implements org.reactivestreams.Subscription

Created by johnmcclean on 12/01/2017.

Field Summary

Fields

Modifier and Type	Field and Description
boolean	isOpen
protected java.util.concurrent.atomic.AtomicLong	requested

Constructor Summary

Constructors

Constructor and Description
StreamSubscription()

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	isActive()
void	request(long n)
boolean	singleActiveRequest(long n, java.util.function.LongConsumer work)

Methods inherited from class java.lang.Object

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

Field Detail

isOpen

public volatile boolean isOpen

requested

protected final java.util.concurrent.atomic.AtomicLong requested

Constructor Detail

StreamSubscription

public StreamSubscription()

Method Detail

isActive

public boolean isActive()

singleActiveRequest

public boolean singleActiveRequest(long n,
                                   java.util.function.LongConsumer work)

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription