Class Implicits.TimedFlowDsl$

  • Enclosing class:
    Implicits

    public static class Implicits.TimedFlowDsl$
    extends java.lang.Object
    Deprecated.
    Moved to the akka/akka-stream-contrib project. Since 2.4.5.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static Implicits.TimedFlowDsl$ MODULE$
      Deprecated.
      Static reference to the singleton instance of this Scala object.
    • Constructor Summary

      Constructors 
      Constructor Description
      TimedFlowDsl$()
      Deprecated.
       
    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      <I,​O,​Mat>
      boolean
      equals$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this, java.lang.Object x$1)
      Deprecated.
       
      <I,​O,​Mat>
      int
      hashCode$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this)
      Deprecated.
       
      <Out,​Mat2,​I,​O,​Mat>
      Flow<I,​Out,​Mat2>
      timed$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this, scala.Function1<Flow<I,​O,​Mat>,​Flow<I,​Out,​Mat2>> measuredOps, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
      Deprecated.
      Measures time from receiving the first element and completion events - one for each subscriber of this Flow.
      <I,​O,​Mat>
      Flow<I,​O,​Mat>
      timedIntervalBetween$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this, scala.Function1<O,​java.lang.Object> matching, scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
      Deprecated.
      Measures rolling interval between immediately subsequent matching(o: O) elements.
      • Methods inherited from class java.lang.Object

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

      • MODULE$

        public static final Implicits.TimedFlowDsl$ MODULE$
        Deprecated.
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • TimedFlowDsl$

        public TimedFlowDsl$()
        Deprecated.
    • Method Detail

      • timed$extension

        public final <Out,​Mat2,​I,​O,​Mat> Flow<I,​Out,​Mat2> timed$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this,
                                                                                                             scala.Function1<Flow<I,​O,​Mat>,​Flow<I,​Out,​Mat2>> measuredOps,
                                                                                                             scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onComplete)
        Deprecated.
        Measures time from receiving the first element and completion events - one for each subscriber of this Flow.
        Parameters:
        $this - (undocumented)
        measuredOps - (undocumented)
        onComplete - (undocumented)
        Returns:
        (undocumented)
      • timedIntervalBetween$extension

        public final <I,​O,​Mat> Flow<I,​O,​Mat> timedIntervalBetween$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this,
                                                                                                    scala.Function1<O,​java.lang.Object> matching,
                                                                                                    scala.Function1<scala.concurrent.duration.FiniteDuration,​scala.runtime.BoxedUnit> onInterval)
        Deprecated.
        Measures rolling interval between immediately subsequent matching(o: O) elements.
        Parameters:
        $this - (undocumented)
        matching - (undocumented)
        onInterval - (undocumented)
        Returns:
        (undocumented)
      • hashCode$extension

        public final <I,​O,​Mat> int hashCode$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this)
        Deprecated.
      • equals$extension

        public final <I,​O,​Mat> boolean equals$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this,
                                                                    java.lang.Object x$1)
        Deprecated.