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
All Methods Static Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceActorGraphInterpreter.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 interfaceActorGraphInterpreter.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 interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-