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
All Methods Static Methods Abstract Methods Concrete Methods 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()
-
-
-
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)
-
-