Class Timed


  • public class Timed
    extends java.lang.Object
    Deprecated.
    Moved to the akka/akka-stream-contrib project. Since 2.4.5.
    Measures rolling interval between immediately subsequent matching(o: O) elements.
    • Constructor Summary

      Constructors 
      Constructor Description
      Timed()
      Deprecated.
       
    • Method Summary

      All Methods Static Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      static <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.
       
      static <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.
       
      static <I,​O,​Mat>
      Flow<I,​O,​Mat>
      timedIntervalBetween​(Flow<I,​O,​Mat> flow, scala.Function1<O,​java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
      Deprecated.
       
      static <O,​Mat>
      Source<O,​Mat>
      timedIntervalBetween​(Source<O,​Mat> source, scala.Function1<O,​java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
      Deprecated.
       
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • Timed

        public Timed()
        Deprecated.
    • Method Detail

      • timed

        public static <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.
      • timed

        public static <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.
      • timedIntervalBetween

        public static <O,​Mat> Source<O,​Mat> timedIntervalBetween​(Source<O,​Mat> source,
                                                                             scala.Function1<O,​java.lang.Object> matching,
                                                                             scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
        Deprecated.
      • timedIntervalBetween

        public static <I,​O,​Mat> Flow<I,​O,​Mat> timedIntervalBetween​(Flow<I,​O,​Mat> flow,
                                                                                           scala.Function1<O,​java.lang.Object> matching,
                                                                                           scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
        Deprecated.