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 and Description
static NoMaterializer$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
NoMaterializer$()

Method Summary

Modifier and Type	Method and 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 initialAttributes) This method interprets the given Flow description and creates the running stream using an explicitly provided Attributes as top level attributes.
Cancellable	scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task) Interface for stages 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 stages that need timer services for their functionality.
Materializer	withNamePrefix(java.lang.String name) The namePrefix shall be used for deriving the names of processing entities that are created during materialization.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final NoMaterializer$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

NoMaterializer$

public NoMaterializer$()

Method Detail

withNamePrefix

public Materializer withNamePrefix(java.lang.String name)

Description copied from class: Materializer

The namePrefix shall be used for deriving the names of processing entities that are created during materialization. This is meant to aid logging and failure reporting both during materialization and while the stream is running.

Specified by:

withNamePrefix in class Materializer

Parameters:

name - (undocumented)

Returns:

(undocumented)

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 class Materializer

Parameters:

runnable - (undocumented)

Returns:

(undocumented)

materialize

public <Mat> Mat materialize(Graph<ClosedShape,Mat> runnable,
                             Attributes initialAttributes)

Description copied from class: Materializer

This method interprets the given Flow description and creates the running stream using an explicitly provided Attributes as top level attributes. The result can be highly implementation specific, ranging from local actor chains to remote-deployed processing networks.

Specified by:

materialize in class Materializer

Parameters:

runnable - (undocumented)

initialAttributes - (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. This ExecutionContextExecutor can be used by parts of the flow to submit processing jobs for execution, run Future callbacks, etc.

Specified by:

executionContext in class Materializer

Returns:

(undocumented)

scheduleOnce

public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
                                java.lang.Runnable task)

Description copied from class: Materializer

Interface for stages that need timer services for their functionality. Schedules a single task with the given delay.

Specified by:

scheduleOnce in class Materializer

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 stages that need timer services for their functionality. Schedules a repeated task with the given interval between invocations.

Specified by:

schedulePeriodically in class Materializer

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.