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 API

Contains 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. Corresponds to the array slot in the GraphInterpreter.GraphAssembly param: inOwnerId Identifier of the owner of the input side of the connection. Corresponds to the array slot in the GraphInterpreter.GraphAssembly param: inOwner The stage logic that corresponds to the input side of the connection. param: outOwnerId Identifier of the owner of the output side of the connection. Corresponds to the array slot in the GraphInterpreter.GraphAssembly param: outOwner The stage 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 and Description
Connection(int id, int inOwnerId, GraphStageLogic inOwner, int outOwnerId, GraphStageLogic outOwner, InHandler inHandler, OutHandler outHandler)

Method Summary

Modifier and Type	Method and Description
int	id()
InHandler	inHandler()
GraphStageLogic	inOwner()
int	inOwnerId()
OutHandler	outHandler()
GraphStageLogic	outOwner()
int	outOwnerId()
int	portState()
java.lang.Object	slot()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Connection

public Connection(int id,
                  int inOwnerId,
                  GraphStageLogic inOwner,
                  int outOwnerId,
                  GraphStageLogic outOwner,
                  InHandler inHandler,
                  OutHandler outHandler)

Method Detail

id

public int id()

inOwnerId

public int inOwnerId()

inOwner

public GraphStageLogic inOwner()

outOwnerId

public int outOwnerId()

outOwner

public GraphStageLogic outOwner()

inHandler

public InHandler inHandler()

outHandler

public OutHandler outHandler()

portState

public int portState()

slot

public java.lang.Object slot()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object