Class Implicits.TimedSourceDsl$

  • Enclosing class:
    Implicits

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

      • MODULE$

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

      • TimedSourceDsl$

        public TimedSourceDsl$()
        Deprecated.
    • Method Detail

      • timed$extension

        public final <O,​Mat2,​I,​Mat> Source<O,​Mat2> timed$extension​(Implicits.TimedSourceDsl<I,​Mat> $this,
                                                                                           scala.Function1<Source<I,​Mat>,​Source<O,​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,​Mat> Source<I,​Mat> timedIntervalBetween$extension​(Implicits.TimedSourceDsl<I,​Mat> $this,
                                                                                      scala.Function1<I,​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,​Mat> int hashCode$extension​(Implicits.TimedSourceDsl<I,​Mat> $this)
        Deprecated.
      • equals$extension

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