Package akka.stream.impl.fusing
Class GraphInterpreter.Connection
- java.lang.Object
-
- akka.stream.impl.fusing.GraphInterpreter.Connection
-
- Enclosing class:
- GraphInterpreter
public static final class GraphInterpreter.Connection extends java.lang.Object
INERNAL APIContains all the necessary information for the GraphInterpreter to be able to implement a connection between an output and input ports.
param: id Identifier of the connection. param: inOwner The operator logic that corresponds to the input side of the connection. param: outOwner The operator logic that corresponds to the output side of the connection. param: inHandler The handler that contains the callback for input events. param: outHandler The handler that contains the callback for output events.
-
-
Constructor Summary
Constructors Constructor Description Connection(int id, GraphStageLogic inOwner, GraphStageLogic outOwner, InHandler inHandler, OutHandler outHandler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
id()
void
id_$eq(int x$1)
InHandler
inHandler()
void
inHandler_$eq(InHandler x$1)
GraphStageLogic
inOwner()
void
inOwner_$eq(GraphStageLogic x$1)
OutHandler
outHandler()
void
outHandler_$eq(OutHandler x$1)
GraphStageLogic
outOwner()
void
outOwner_$eq(GraphStageLogic x$1)
int
portState()
void
portState_$eq(int x$1)
java.lang.Object
slot()
void
slot_$eq(java.lang.Object x$1)
-
-
-
Constructor Detail
-
Connection
public Connection(int id, GraphStageLogic inOwner, GraphStageLogic outOwner, InHandler inHandler, OutHandler outHandler)
-
-
Method Detail
-
id
public int id()
-
id_$eq
public void id_$eq(int x$1)
-
inHandler
public InHandler inHandler()
-
inHandler_$eq
public void inHandler_$eq(InHandler x$1)
-
inOwner
public GraphStageLogic inOwner()
-
inOwner_$eq
public void inOwner_$eq(GraphStageLogic x$1)
-
outHandler
public OutHandler outHandler()
-
outHandler_$eq
public void outHandler_$eq(OutHandler x$1)
-
outOwner
public GraphStageLogic outOwner()
-
outOwner_$eq
public void outOwner_$eq(GraphStageLogic x$1)
-
portState
public int portState()
-
portState_$eq
public void portState_$eq(int x$1)
-
slot
public java.lang.Object slot()
-
slot_$eq
public void slot_$eq(java.lang.Object x$1)
-
-