public static final class ActorGraphInterpreter.OnSubscribe extends java.lang.Object implements ActorGraphInterpreter.BoundaryEvent, scala.Product, scala.Serializable
Constructor and Description |
---|
OnSubscribe(GraphInterpreterShell shell,
int id,
org.reactivestreams.Subscription subscription) |
Modifier and Type | Method and Description |
---|---|
int |
id() |
GraphInterpreterShell |
shell() |
org.reactivestreams.Subscription |
subscription() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public OnSubscribe(GraphInterpreterShell shell, int id, org.reactivestreams.Subscription subscription)
public GraphInterpreterShell shell()
shell
in interface ActorGraphInterpreter.BoundaryEvent
public int id()
public org.reactivestreams.Subscription subscription()