Packages

c

akka.stream.extra.Implicits

TimedSourceDsl

implicit final class TimedSourceDsl[I, Mat] extends AnyVal

Provides time measurement utilities on Stream elements.

See Timed

Source
Implicits.scala
Linear Supertypes
AnyVal, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimedSourceDsl
  2. AnyVal
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TimedSourceDsl(source: Source[I, Mat])

Value Members

  1. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  2. val source: Source[I, Mat]
  3. def timed[O, Mat2](measuredOps: (Source[I, Mat]) ⇒ Source[O, Mat2], onComplete: (FiniteDuration) ⇒ Unit): Source[O, Mat2]

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

  4. def timedIntervalBetween(matching: (I) ⇒ Boolean, onInterval: (FiniteDuration) ⇒ Unit): Source[I, Mat]

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