akka.stream.impl

Class SubFusingActorMaterializerImpl

java.lang.Object

akka.stream.Materializer

akka.stream.impl.SubFusingActorMaterializerImpl

public class SubFusingActorMaterializerImpl
extends Materializer

Constructor Summary

Constructors

Constructor and Description
SubFusingActorMaterializerImpl(ExtendedActorMaterializer delegate, scala.Function1<GraphInterpreterShell,ActorRef> registerShell)

Method Summary

Modifier and Type	Method and Description
ExtendedActorMaterializer	delegate()
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.
SubFusingActorMaterializerImpl	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

Constructor Detail

SubFusingActorMaterializerImpl

public SubFusingActorMaterializerImpl(ExtendedActorMaterializer delegate,
                                      scala.Function1<GraphInterpreterShell,ActorRef> registerShell)

Method Detail

delegate

public ExtendedActorMaterializer delegate()

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)

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)

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.

withNamePrefix

public SubFusingActorMaterializerImpl 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)