Package akka.stream.extra

Class Implicits

java.lang.Object

akka.stream.extra.Implicits

public class Implicits
extends java.lang.Object

Provides time measurement utilities on Stream elements.

See Timed

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Implicits.TimedFlowDsl<I,O,Mat>
static class	Implicits.TimedFlowDsl$
static class	Implicits.TimedSourceDsl<I,Mat>
static class	Implicits.TimedSourceDsl$

Constructor Summary

Constructors

Constructor	Description
Implicits()

Method Summary

Modifier and Type	Method	Description
static <I,O,Mat> Implicits.TimedFlowDsl<I,O,Mat>	TimedFlowDsl(Flow<I,O,Mat> flow)
static <I,Mat> Implicits.TimedSourceDsl<I,Mat>	TimedSourceDsl(Source<I,Mat> source)

Methods inherited from class java.lang.Object

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

Constructor Detail

Implicits

public Implicits()

Method Detail

TimedSourceDsl

public static <I,Mat> Implicits.TimedSourceDsl<I,Mat> TimedSourceDsl(Source<I,Mat> source)

TimedFlowDsl

public static <I,O,Mat> Implicits.TimedFlowDsl<I,O,Mat> TimedFlowDsl(Flow<I,O,Mat> flow)