Package akka.stream.extra

Class Implicits.TimedFlowDsl$

  • Enclosing class:
    Implicits
    public static class Implicits.TimedFlowDsl$
extends java.lang.Object

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      TimedFlowDsl$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <I,​O,​Mat>
      boolean      		 equals$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this, java.lang.Object x$1)  
      <I,​O,​Mat>
      int      		 hashCode$extension​(Implicits.TimedFlowDsl<I,​O,​Mat> $this)  
      <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)
      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)
      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$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • TimedFlowDsl$

        public TimedFlowDsl$()

    • 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)
        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)
        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)

      • equals$extension

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