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
All Methods Static Methods Concrete Methods 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)
-
-
-
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)
-
-