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 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. 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

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()	See GraphInterpreter about possible states
void	portState_$eq(int x$1)
java.lang.Object	slot()	Can either be * an in-flight element * a failure (with an optional in-flight element), if elem.isInstanceOf[Failed] * a cancellation cause, if elem.isInstanceOf[Cancelled]
void	slot_$eq(java.lang.Object x$1)

Methods inherited from class java.lang.Object

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

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()

See GraphInterpreter about possible states

portState_$eq

public void portState_$eq(int x$1)

slot

public java.lang.Object slot()

Can either be * an in-flight element * a failure (with an optional in-flight element), if elem.isInstanceOf[Failed] * a cancellation cause, if elem.isInstanceOf[Cancelled]

slot_$eq

public void slot_$eq(java.lang.Object x$1)