Packages

implicit final class TimedFlowDsl[I, O, Mat] extends AnyVal

Provides time measurement utilities on Stream elements.

See Timed

Source
Implicits.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimedFlowDsl
  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 TimedFlowDsl(flow: Flow[I, O, Mat])

Value Members

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

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

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

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