java.lang.Object
- akka.stream.stage.GraphStageLogic
- - akka.stream.impl.fusing.GraphInterpreter.DownstreamBoundaryStageLogic<java.lang.Object>
  - - akka.stream.impl.fusing.ActorGraphInterpreter.ActorOutputBoundary

All Implemented Interfaces:: InHandler

Enclosing class:: ActorGraphInterpreter

public static class ActorGraphInterpreter.ActorOutputBoundary
extends GraphInterpreter.DownstreamBoundaryStageLogic<java.lang.Object>
implements InHandler

Nested Class Summary
- Nested classes/interfaces inherited from class akka.stream.stage.GraphStageLogic
  GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$

Constructor Summary

Constructors
Constructor Description

ActorOutputBoundary(GraphInterpreterShell shell, java.lang.String internalPortName)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`cancel()`
`void`	`fail(java.lang.Throwable e)`
`ActorRef`	`getActor()`
`Inlet<java.lang.Object>`	`in()`
`java.lang.String`	`internalPortName()`
`void`	`onPush()`	Called when the input port has a new element available.
`void`	`onUpstreamFailure(java.lang.Throwable cause)`	Called when the input port has failed.
`void`	`onUpstreamFinish()`	Called when the input port is finished.
`ActorGraphInterpreter.OutputBoundaryPublisher`	`publisher()`
`void`	`requestMore(long elements)`
`void`	`setActor(ActorRef actor)`
`GraphInterpreterShell`	`shell()`
`void`	`subscribePending()`
`java.lang.String`	`toString()`

Methods inherited from class akka.stream.stage.GraphStageLogic
abortEmitting, abortReading, afterPostStop, attributes, attributes_$eq, beforePreStart, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, inHandler, interpreter, interpreter_$eq, isAvailable, isAvailable, isClosed, isClosed, materializer, NoPromise, onFeedbackDispatched, originalStage, originalStage_$eq, outCount, outHandler, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, portToConn, postStop, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, stageId, stageId_$eq, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - ActorOutputBoundary
```
public ActorOutputBoundary(GraphInterpreterShell shell,
                           java.lang.String internalPortName)
```
- Method Detail
  - cancel
```
public void cancel()
```
  - fail
```
public void fail(java.lang.Throwable e)
```
  - getActor
```
public ActorRef getActor()
```
  - in
```
public Inlet<java.lang.Object> in()
```
    Specified by:
    
    in in class GraphInterpreter.DownstreamBoundaryStageLogic<java.lang.Object>
  - internalPortName
```
public java.lang.String internalPortName()
```
  - onPush
```
public void onPush()
```
    Description copied from interface: InHandler
    
    Called when the input port has a new element available. The actual element can be retrieved via the {@link GraphStageLogic.grab()} method.
    
    Specified by:
    
    onPush in interface InHandler
  - onUpstreamFailure
```
public void onUpstreamFailure(java.lang.Throwable cause)
```
    Description copied from interface: InHandler
    
    Called when the input port has failed. After this callback no other callbacks will be called for this port.
    
    Specified by:
    
    onUpstreamFailure in interface InHandler
    
    Parameters:
    
    cause - (undocumented)
  - onUpstreamFinish
```
public void onUpstreamFinish()
```
    Description copied from interface: InHandler
    
    Called when the input port is finished. After this callback no other callbacks will be called for this port.
    
    Specified by:
    
    onUpstreamFinish in interface InHandler
  - publisher
```
public ActorGraphInterpreter.OutputBoundaryPublisher publisher()
```
  - requestMore
```
public void requestMore(long elements)
```
  - setActor
```
public void setActor(ActorRef actor)
```
  - shell
```
public GraphInterpreterShell shell()
```
  - subscribePending
```
public void subscribePending()
```
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object

Class ActorGraphInterpreter.ActorOutputBoundary

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.stage.GraphStageLogic

Constructor Summary

Method Summary

Methods inherited from class akka.stream.stage.GraphStageLogic

Methods inherited from class java.lang.Object

Constructor Detail

ActorOutputBoundary

Method Detail

cancel

fail

getActor

in

internalPortName

onPush

onUpstreamFailure

onUpstreamFinish

publisher

requestMore

setActor

shell

subscribePending

toString