public class VirtualProcessor.WrappedSubscription$
extends java.lang.Object
implements scala.Serializable
Modifier and Type | Class and Description |
---|---|
class |
VirtualProcessor.WrappedSubscription$.Buffering |
class |
VirtualProcessor.WrappedSubscription$.Buffering$ |
class |
VirtualProcessor.WrappedSubscription$.PassThrough$ |
static interface |
VirtualProcessor.WrappedSubscription$.SubscriptionState |
Constructor and Description |
---|
WrappedSubscription$() |
Modifier and Type | Method and Description |
---|---|
VirtualProcessor.WrappedSubscription$.Buffering |
NoBufferedDemand() |
VirtualProcessor.WrappedSubscription$.PassThrough$ |
PassThrough() |
public VirtualProcessor.WrappedSubscription$.PassThrough$ PassThrough()
public VirtualProcessor.WrappedSubscription$.Buffering NoBufferedDemand()