Interface TimedIntervalBetweenOps

  • All Known Implementing Classes:
    Timed$

    public interface TimedIntervalBetweenOps
    INTERNAL API

    Provides operations needed to implement the timedIntervalBetween DSL

    • Method Summary

      All Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      <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.
      Moved to the akka/akka-stream-contrib project.
      <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.
      Moved to the akka/akka-stream-contrib project.
    • Method Detail

      • timedIntervalBetween

        <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.
        Moved to the akka/akka-stream-contrib project. Since 2.4.5.
        Measures rolling interval between immediately subsequent matching(o: O) elements.
        Parameters:
        source - (undocumented)
        matching - (undocumented)
        onInterval - (undocumented)
        Returns:
        (undocumented)
      • timedIntervalBetween

        <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.
        Moved to the akka/akka-stream-contrib project. Since 2.4.5.
        Measures rolling interval between immediately subsequent matching(o: O) elements.
        Parameters:
        flow - (undocumented)
        matching - (undocumented)
        onInterval - (undocumented)
        Returns:
        (undocumented)