akka.stream.impl

Class CancelledSubscription$

java.lang.Object

akka.stream.impl.CancelledSubscription$

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription, scala.Equals, scala.Product

public class CancelledSubscription$
extends java.lang.Object
implements org.reactivestreams.Subscription, scala.Product, scala.Serializable

INTERNAL API This is only a legal subscription when it is immediately followed by a termination signal (onComplete, onError).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static CancelledSubscription$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
CancelledSubscription$()

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	request(long elements)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final CancelledSubscription$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

CancelledSubscription$

public CancelledSubscription$()

Method Detail

request

public void request(long elements)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription