Module "xform/benchmark"

benchmark

• benchmark(): Transducer<any, number>
• benchmark(src: Iterable<any>): IterableIterator<number>

• Stateful transducer. Ignores the actual input values, but produces time measurements since last value processed, e.g. for use in async usage contexts.

  example

  // example using @thi.ng/rstream
  rstream
      .fromInterval(1000)
      .subscribe(
          rstream.trace(),
          comp(benchmark(), movingAverage(60))
      )

  Returns Transducer<any, number>

• Parameters

  • src: Iterable<any>

  Returns IterableIterator<number>