Package akka.stream.impl

Class CancelledSubscription

java.lang.Object

akka.stream.impl.CancelledSubscription

public class CancelledSubscription
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor	Description
CancelledSubscription()

Method Summary

Modifier and Type	Method	Description
static void	cancel()
static boolean	canEqual(java.lang.Object x$1)
abstract static boolean	equals(java.lang.Object that)
static int	hashCode()
static int	productArity()
static java.lang.Object	productElement(int x$1)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
static void	request(long elements)
static java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CancelledSubscription

public CancelledSubscription()

Method Detail

request

public static void request(long elements)

cancel

public static void cancel()

productPrefix

public static java.lang.String productPrefix()

productArity

public static int productArity()

productElement

public static java.lang.Object productElement(int x$1)

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

canEqual

public static boolean canEqual(java.lang.Object x$1)

hashCode

public static int hashCode()

toString

public static java.lang.String toString()

equals

public abstract static boolean equals(java.lang.Object that)