Skip to content

Latest commit

 

History

History
39 lines (30 loc) · 915 Bytes

File metadata and controls

39 lines (30 loc) · 915 Bytes

emit once

timer(msDelay) will emit once after a given delay

const { rxObserver } = require('api/v0.3');
const { timer } = require('rxjs');
const { take } = require('rxjs/operators');

// will emit once in 10ms
timer(10)
  .subscribe(rxObserver('timer(10)'));

emit with interval

timer(msDelay, msInterval) after a given delay will start emitting sequential number values with a given interval

const { rxObserver } = require('api/v0.3');
const { timer } = require('rxjs');
const { take } = require('rxjs/operators');

// will start emiting in 10ms
// with 5ms interval
timer(10, 5).pipe(
    take(4)
  )
  .subscribe(rxObserver('timer(10, 5)'));