abstract class TimerGraphStageLogic extends GraphStageLogic
- Alphabetic
- By Inheritance
- TimerGraphStageLogic
- GraphStageLogic
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Type Members
-
class
SubSinkInlet[T] extends AnyRef
INTERNAL API
INTERNAL API
This allows the dynamic creation of an Inlet for a GraphStage which is connected to a Sink that is available for materialization (e.g. using the
subFusingMaterializer
). Care needs to be taken to cancel this Inlet when the operator shuts down lest the corresponding Sink be left hanging.- Definition Classes
- GraphStageLogic
-
class
SubSourceOutlet[T] extends AnyRef
INTERNAL API
INTERNAL API
This allows the dynamic creation of an Outlet for a GraphStage which is connected to a Source that is available for materialization (e.g. using the
subFusingMaterializer
). Care needs to be taken to complete this Outlet when the operator shuts down lest the corresponding Sink be left hanging. It is good practice to use thetimeout
method to cancel this Outlet in case the corresponding Source is not materialized within a given time limit, see e.g. ActorMaterializerSettings.- Definition Classes
- GraphStageLogic
Value Members
-
final
def
completeStage(): Unit
Automatically invokes cancel() or complete() on all the input or output ports that have been called, then marks the operator as stopped.
Automatically invokes cancel() or complete() on all the input or output ports that have been called, then marks the operator as stopped.
- Definition Classes
- GraphStageLogic
-
final
def
failStage(ex: Throwable): Unit
Automatically invokes cancel() or fail() on all the input or output ports that have been called, then marks the operator as stopped.
Automatically invokes cancel() or fail() on all the input or output ports that have been called, then marks the operator as stopped.
- Definition Classes
- GraphStageLogic
-
final
def
getAsyncCallback[T](handler: (T) ⇒ Unit): AsyncCallback[T]
Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification.
Obtain a callback object that can be used asynchronously to re-enter the current GraphStage with an asynchronous notification. The invoke() method of the returned AsyncCallback is safe to be called from other threads. It will in the background thread-safely delegate to the passed callback function. I.e. invoke() will be called by other thread and the passed handler will be invoked eventually in a thread-safe way by the execution environment.
In case stream is not yet materialized AsyncCallback will buffer events until stream is available.
AsyncCallback.invokeWithFeedback() has an internal promise that will be failed if event cannot be processed due to stream completion.
To be thread safe this method must only be called from either the constructor of the graph operator during materialization or one of the methods invoked by the graph operator machinery, such as
onPush
andonPull
.This object can be cached and reused within the same GraphStageLogic.
- Definition Classes
- GraphStageLogic
-
val
inCount: Int
- Definition Classes
- GraphStageLogic
-
final
def
isAvailable[T](out: Outlet[T]): Boolean
Return true if the given output port is ready to be pushed.
Return true if the given output port is ready to be pushed.
- Definition Classes
- GraphStageLogic
-
val
outCount: Int
- Definition Classes
- GraphStageLogic
-
def
postStop(): Unit
Invoked after processing of external events stopped because the operator is about to stop or fail.
Invoked after processing of external events stopped because the operator is about to stop or fail.
- Definition Classes
- GraphStageLogic
- Annotations
- @throws( classOf[Exception] )
-
def
preStart(): Unit
Invoked before any external events are processed, at the startup of the operator.
Invoked before any external events are processed, at the startup of the operator.
- Definition Classes
- GraphStageLogic
- Annotations
- @throws( classOf[Exception] )
-
final
def
stageActor: StageActor
- Definition Classes
- GraphStageLogic