implicit final class TimedSourceDsl[I, Mat] extends AnyVal
Provides time measurement utilities on Stream elements.
See Timed
- Source
- Implicits.scala
Linear Supertypes
Type Hierarchy
Ordering
- Alphabetic
- By Inheritance
Inherited
- TimedSourceDsl
- AnyVal
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
- val source: Source[I, Mat]
-
def
timed[O, Mat2](measuredOps: (Source[I, Mat]) ⇒ Source[O, Mat2], onComplete: (FiniteDuration) ⇒ Unit): Source[O, Mat2]
Measures time from receiving the first element and completion events - one for each subscriber of this
Flow
.Measures time from receiving the first element and completion events - one for each subscriber of this
Flow
.- Annotations
- @silent()
-
def
timedIntervalBetween(matching: (I) ⇒ Boolean, onInterval: (FiniteDuration) ⇒ Unit): Source[I, Mat]
Measures rolling interval between immediately subsequent
matching(o: O)
elements.Measures rolling interval between immediately subsequent
matching(o: O)
elements.- Annotations
- @silent()