Package akka.stream.impl
Class VirtualProcessor.WrappedSubscription$
- java.lang.Object
-
- akka.stream.impl.VirtualProcessor.WrappedSubscription$
-
- All Implemented Interfaces:
java.io.Serializable
,scala.Serializable
- Enclosing class:
- VirtualProcessor<T>
public class VirtualProcessor.WrappedSubscription$ extends java.lang.Object implements scala.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
VirtualProcessor.WrappedSubscription$.Buffering
class
VirtualProcessor.WrappedSubscription$.Buffering$
class
VirtualProcessor.WrappedSubscription$.PassThrough
class
VirtualProcessor.WrappedSubscription$.PassThrough$
static interface
VirtualProcessor.WrappedSubscription$.SubscriptionState
-
Constructor Summary
Constructors Constructor Description WrappedSubscription$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description VirtualProcessor.WrappedSubscription$.Buffering$
Buffering()
VirtualProcessor.WrappedSubscription$.Buffering
NoBufferedDemand()
VirtualProcessor.WrappedSubscription$.PassThrough$
PassThrough()
-
-
-
Method Detail
-
PassThrough
public VirtualProcessor.WrappedSubscription$.PassThrough$ PassThrough()
-
Buffering
public VirtualProcessor.WrappedSubscription$.Buffering$ Buffering()
-
NoBufferedDemand
public VirtualProcessor.WrappedSubscription$.Buffering NoBufferedDemand()
-
-