Package akka.stream

Class NoMaterializer

java.lang.Object

akka.stream.NoMaterializer

public class NoMaterializer
extends java.lang.Object

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
NoMaterializer()

Method Summary

Modifier and Type	Method	Description
static scala.concurrent.ExecutionContextExecutor	executionContext()
static <Mat> Mat	materialize(Graph<ClosedShape,Mat> runnable)
static <Mat> Mat	materialize(Graph<ClosedShape,Mat> runnable, Attributes defaultAttributes)
static Cancellable	scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task)
static Cancellable	schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, java.lang.Runnable task)
static Materializer	withNamePrefix(java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoMaterializer

public NoMaterializer()

Method Detail

withNamePrefix

public static Materializer withNamePrefix(java.lang.String name)

materialize

public static <Mat> Mat materialize(Graph<ClosedShape,Mat> runnable)

materialize

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

executionContext

public static scala.concurrent.ExecutionContextExecutor executionContext()

scheduleOnce

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

schedulePeriodically

public static Cancellable schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay,
                                               scala.concurrent.duration.FiniteDuration interval,
                                               java.lang.Runnable task)