Package akka.stream.impl.fusing

Class GraphInterpreterShell.AsyncInput

java.lang.Object

akka.stream.impl.fusing.GraphInterpreterShell.AsyncInput

All Implemented Interfaces:

DeadLetterSuppression, NoSerializationVerificationNeeded, ActorGraphInterpreter.BoundaryEvent, java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

Enclosing class:

GraphInterpreterShell

public class GraphInterpreterShell.AsyncInput
extends java.lang.Object
implements ActorGraphInterpreter.BoundaryEvent, scala.Product, scala.Serializable

param: promise Will be completed upon processing the event, or failed if processing the event throws if the event isn't ever processed the promise (the operator stops) is failed elsewhere

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AsyncInput(GraphInterpreterShell shell, GraphStageLogic logic, java.lang.Object evt, scala.concurrent.Promise<Done> promise, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)

Method Summary

Modifier and Type	Method	Description
static GraphInterpreterShell.AsyncInput	apply(GraphInterpreterShell shell, GraphStageLogic logic, java.lang.Object evt, scala.concurrent.Promise<Done> promise, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)
boolean	canEqual(java.lang.Object x$1)
GraphInterpreterShell.AsyncInput	copy(GraphInterpreterShell shell, GraphStageLogic logic, java.lang.Object evt, scala.concurrent.Promise<Done> promise, scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)
GraphInterpreterShell	copy$default$1()
GraphStageLogic	copy$default$2()
java.lang.Object	copy$default$3()
scala.concurrent.Promise<Done>	copy$default$4()
scala.Function1<java.lang.Object,scala.runtime.BoxedUnit>	copy$default$5()
boolean	equals(java.lang.Object x$1)
java.lang.Object	evt()
int	execute(int eventLimit)
scala.Function1<java.lang.Object,scala.runtime.BoxedUnit>	handler()
int	hashCode()
GraphStageLogic	logic()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
scala.concurrent.Promise<Done>	promise()
GraphInterpreterShell	shell()
java.lang.String	toString()
static scala.Option<scala.Tuple5<GraphInterpreterShell,GraphStageLogic,java.lang.Object,scala.concurrent.Promise<Done>,scala.Function1<java.lang.Object,scala.runtime.BoxedUnit>>>	unapply(GraphInterpreterShell.AsyncInput x$0)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AsyncInput

public AsyncInput(GraphInterpreterShell shell,
                  GraphStageLogic logic,
                  java.lang.Object evt,
                  scala.concurrent.Promise<Done> promise,
                  scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)

Method Detail

apply

public static GraphInterpreterShell.AsyncInput apply(GraphInterpreterShell shell,
                                                     GraphStageLogic logic,
                                                     java.lang.Object evt,
                                                     scala.concurrent.Promise<Done> promise,
                                                     scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)

unapply

public static scala.Option<scala.Tuple5<GraphInterpreterShell,GraphStageLogic,java.lang.Object,scala.concurrent.Promise<Done>,scala.Function1<java.lang.Object,scala.runtime.BoxedUnit>>> unapply(GraphInterpreterShell.AsyncInput x$0)

shell

public GraphInterpreterShell shell()

Specified by:

shell in interface ActorGraphInterpreter.BoundaryEvent

logic

public GraphStageLogic logic()

evt

public java.lang.Object evt()

promise

public scala.concurrent.Promise<Done> promise()

handler

public scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler()

execute

public int execute(int eventLimit)

Specified by:

execute in interface ActorGraphInterpreter.BoundaryEvent

copy

public GraphInterpreterShell.AsyncInput copy(GraphInterpreterShell shell,
                                             GraphStageLogic logic,
                                             java.lang.Object evt,
                                             scala.concurrent.Promise<Done> promise,
                                             scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> handler)

copy$default$1

public GraphInterpreterShell copy$default$1()

copy$default$2

public GraphStageLogic copy$default$2()

copy$default$3

public java.lang.Object copy$default$3()

copy$default$4

public scala.concurrent.Promise<Done> copy$default$4()

copy$default$5

public scala.Function1<java.lang.Object,scala.runtime.BoxedUnit> copy$default$5()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object