Package akka.stream.extra

Class Implicits.TimedSourceDsl$

java.lang.Object

akka.stream.extra.Implicits.TimedSourceDsl$

Enclosing class:

Implicits

public static class Implicits.TimedSourceDsl$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static Implicits.TimedSourceDsl$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
TimedSourceDsl$()

Method Summary

Modifier and Type	Method	Description
<I,Mat> boolean	equals$extension(Implicits.TimedSourceDsl<I,Mat> $this, java.lang.Object x$1)
<I,Mat> int	hashCode$extension(Implicits.TimedSourceDsl<I,Mat> $this)
<O,Mat2,I,Mat> Source<O,Mat2>	timed$extension(Implicits.TimedSourceDsl<I,Mat> $this, scala.Function1<Source<I,Mat>,Source<O,Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)	Measures time from receiving the first element and completion events - one for each subscriber of this Flow.
<I,Mat> Source<I,Mat>	timedIntervalBetween$extension(Implicits.TimedSourceDsl<I,Mat> $this, scala.Function1<I,java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)	Measures rolling interval between immediately subsequent matching(o: O) elements.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Implicits.TimedSourceDsl$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

TimedSourceDsl$

public TimedSourceDsl$()

Method Detail

timed$extension

public final <O,Mat2,I,Mat> Source<O,Mat2> timed$extension(Implicits.TimedSourceDsl<I,Mat> $this,
                                                                                   scala.Function1<Source<I,Mat>,Source<O,Mat2>> measuredOps,
                                                                                   scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onComplete)

Measures time from receiving the first element and completion events - one for each subscriber of this Flow.

Parameters:

$this - (undocumented)

measuredOps - (undocumented)

onComplete - (undocumented)

Returns:

(undocumented)

timedIntervalBetween$extension

public final <I,Mat> Source<I,Mat> timedIntervalBetween$extension(Implicits.TimedSourceDsl<I,Mat> $this,
                                                                              scala.Function1<I,java.lang.Object> matching,
                                                                              scala.Function1<scala.concurrent.duration.FiniteDuration,scala.runtime.BoxedUnit> onInterval)

Measures rolling interval between immediately subsequent matching(o: O) elements.

Parameters:

$this - (undocumented)

matching - (undocumented)

onInterval - (undocumented)

Returns:

(undocumented)

hashCode$extension

public final <I,Mat> int hashCode$extension(Implicits.TimedSourceDsl<I,Mat> $this)

equals$extension

public final <I,Mat> boolean equals$extension(Implicits.TimedSourceDsl<I,Mat> $this,
                                                    java.lang.Object x$1)