Interface TimedOps

  • All Known Implementing Classes:
    Timed$

    public interface TimedOps
    INTERNAL API

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

    • Method Summary

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      <I,​O,​Out,​Mat,​Mat2>
      Flow<I,​Out,​Mat2>
      timed​(Flow<I,​O,​Mat> flow, scala.Function1<Flow<I,​O,​Mat>,​Flow<I,​Out,​Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
      Deprecated.
      Moved to the akka/akka-stream-contrib project.
      <I,​O,​Mat,​Mat2>
      Source<O,​Mat2>
      timed​(Source<I,​Mat> source, scala.Function1<Source<I,​Mat>,​Source<O,​Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
      Deprecated.
      Moved to the akka/akka-stream-contrib project.
    • Method Detail

      • timed

        <I,​O,​Mat,​Mat2> Source<O,​Mat2> timed​(Source<I,​Mat> source,
                                                                    scala.Function1<Source<I,​Mat>,​Source<O,​Mat2>> measuredOps,
                                                                    scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
        Deprecated.
        Moved to the akka/akka-stream-contrib project. Since 2.4.5.
        INTERNAL API

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

        Parameters:
        source - (undocumented)
        measuredOps - (undocumented)
        onComplete - (undocumented)
        Returns:
        (undocumented)
      • timed

        <I,​O,​Out,​Mat,​Mat2> Flow<I,​Out,​Mat2> timed​(Flow<I,​O,​Mat> flow,
                                                                                      scala.Function1<Flow<I,​O,​Mat>,​Flow<I,​Out,​Mat2>> measuredOps,
                                                                                      scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
        Deprecated.
        Moved to the akka/akka-stream-contrib project. Since 2.4.5.
        INTERNAL API

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

        Parameters:
        flow - (undocumented)
        measuredOps - (undocumented)
        onComplete - (undocumented)
        Returns:
        (undocumented)