Packages

object Timed extends TimedOps with TimedIntervalBetweenOps

Annotations
@deprecated
Deprecated

(Since version 2.4.5) Moved to the akka/akka-stream-contrib project

Source
Timed.scala
Linear Supertypes
TimedIntervalBetweenOps, TimedOps, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Timed
  2. TimedIntervalBetweenOps
  3. TimedOps
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. final class StartTimed[T] extends SimpleLinearGraphStage[T]
  2. final class StopTimed[T] extends SimpleLinearGraphStage[T]
  3. final class TimedFlowContext extends AnyRef
  4. final class TimedInterval[T] extends SimpleLinearGraphStage[T]

Deprecated Value Members

  1. def timed[I, O, Out, Mat, Mat2](flow: Flow[I, O, Mat], measuredOps: (Flow[I, O, Mat]) ⇒ Flow[I, Out, Mat2], onComplete: (FiniteDuration) ⇒ Unit): Flow[I, Out, Mat2]

    INTERNAL API

    INTERNAL API

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

    Definition Classes
    TimedOps
    Annotations
    @deprecated
    Deprecated

    (Since version 2.4.5) Moved to the akka/akka-stream-contrib project

  2. def timed[I, O, Mat, Mat2](source: Source[I, Mat], measuredOps: (Source[I, Mat]) ⇒ Source[O, Mat2], onComplete: (FiniteDuration) ⇒ Unit): Source[O, Mat2]

    INTERNAL API

    INTERNAL API

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

    Definition Classes
    TimedOps
    Annotations
    @deprecated
    Deprecated

    (Since version 2.4.5) Moved to the akka/akka-stream-contrib project

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

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

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

    Definition Classes
    TimedIntervalBetweenOps
    Annotations
    @deprecated
    Deprecated

    (Since version 2.4.5) Moved to the akka/akka-stream-contrib project

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

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

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

    Definition Classes
    TimedIntervalBetweenOps
    Annotations
    @deprecated
    Deprecated

    (Since version 2.4.5) Moved to the akka/akka-stream-contrib project