Package akka.stream
Class NoMaterializer$
- java.lang.Object
-
- akka.stream.Materializer
-
- akka.stream.NoMaterializer$
-
public class NoMaterializer$ extends Materializer
INTERNAL API
-
-
Field Summary
Fields Modifier and Type Field Description static NoMaterializer$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description NoMaterializer$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.ExecutionContextExecutor
executionContext()
Running a flow graph will require execution resources, as will computations within Sources, Sinks, etc.<Mat> Mat
materialize(Graph<ClosedShape,Mat> runnable)
This method interprets the given Flow description and creates the running stream.<Mat> Mat
materialize(Graph<ClosedShape,Mat> runnable, Attributes defaultAttributes)
This method interprets the given Flow description and creates the running stream using an explicitly providedAttributes
as top level (least specific) attributes that will be defaults for the materialized stream.Cancellable
scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task)
Interface for operators that need timer services for their functionality.Cancellable
schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, java.lang.Runnable task)
Interface for operators that need timer services for their functionality.Materializer
withNamePrefix(java.lang.String name)
-
Methods inherited from class akka.stream.Materializer
matFromSystem
-
-
-
-
Field Detail
-
MODULE$
public static final NoMaterializer$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
withNamePrefix
public Materializer withNamePrefix(java.lang.String name)
- Specified by:
withNamePrefix
in classMaterializer
-
materialize
public <Mat> Mat materialize(Graph<ClosedShape,Mat> runnable)
Description copied from class:Materializer
This method interprets the given Flow description and creates the running stream. The result can be highly implementation specific, ranging from local actor chains to remote-deployed processing networks.- Specified by:
materialize
in classMaterializer
- Parameters:
runnable
- (undocumented)- Returns:
- (undocumented)
-
materialize
public <Mat> Mat materialize(Graph<ClosedShape,Mat> runnable, Attributes defaultAttributes)
Description copied from class:Materializer
This method interprets the given Flow description and creates the running stream using an explicitly providedAttributes
as top level (least specific) attributes that will be defaults for the materialized stream. The result can be highly implementation specific, ranging from local actor chains to remote-deployed processing networks.- Specified by:
materialize
in classMaterializer
- Parameters:
runnable
- (undocumented)defaultAttributes
- (undocumented)- Returns:
- (undocumented)
-
executionContext
public scala.concurrent.ExecutionContextExecutor executionContext()
Description copied from class:Materializer
Running a flow graph will require execution resources, as will computations within Sources, Sinks, etc. ThisExecutionContextExecutor
can be used by parts of the flow to submit processing jobs for execution, run Future callbacks, etc.Note that this is not necessarily the same execution context the stream operator itself is running on.
- Specified by:
executionContext
in classMaterializer
- Returns:
- (undocumented)
-
scheduleOnce
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task)
Description copied from class:Materializer
Interface for operators that need timer services for their functionality. Schedules a single task with the given delay.- Specified by:
scheduleOnce
in classMaterializer
- Parameters:
delay
- (undocumented)task
- (undocumented)- Returns:
- A
Cancellable
that allows cancelling the timer. Cancelling is best effort, if the event has been already enqueued it will not have an effect.
-
schedulePeriodically
public Cancellable schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, java.lang.Runnable task)
Description copied from class:Materializer
Interface for operators that need timer services for their functionality. Schedules a repeated task with the given interval between invocations.- Specified by:
schedulePeriodically
in classMaterializer
- Parameters:
initialDelay
- (undocumented)interval
- (undocumented)task
- (undocumented)- Returns:
- A
Cancellable
that allows cancelling the timer. Cancelling is best effort, if the event has been already enqueued it will not have an effect.
-
-