How to use the delay function from rxjs

apps.js

GitHub: openforis/sepal

5
6
7
8
9
10
11
12
13
14
15


const monitorApps = () =>
    interval(5000).pipe(
        exhaustMap(() => apps$().pipe(
            concatMap(app => updateApp$(app).pipe(
                delay(5000)
            ))
        ))
    ).subscribe({
        error: error => log.fatal('Monitor exited:', error),

45

177

0

auto-reward.js

GitHub: ymuichiro/symbol_web

63
64
65
66
67
68
69
70
71
72
listener.confirmed(bot.address).pipe(
  op.filter(tx => {
    console.log(tx);
    return tx.transactionInfo !== undefined && tx.transactionInfo.hash === signedLockTx.hash;
  }),
  op.delay(5000),
  op.mergeMap(_ => {
    return transactionHttp.announceAggregateBonded(signedAggregateTx);
  })
).subscribe(

5

5

3

testingrxjs.js

GitHub: hermeza30/rxjs-advanced

15
16
17
18
19
20
21
22
23
24
    .subscribe((total) => expect(total).to.equal(45));
});
it("should add numbers together with delay", function (done) {
  const adder = (total, delta) => total + delta;
  from([1, 2, 3, 4, 5, 6, 7, 8, 9])
    .pipe(reduce(adder), delay(1000))
    .subscribe((total) => expect(total).to.equal(45), null, done);
});
it("Usando observables- Fetch wikipedia", function (done) {
  const searchTerm = "reactive+programming";

0

0

2

+ 76 other calls in file

fetchChunk.js

GitHub: lobotomisador/algorithms

2
3
4
5
6
7
8
9
10
11
12
const p = e => new Promise((resolve, reject) => Math.random() < 0.10 ? reject(e) : resolve(e))
// const p2 = e => new Promise(res => res(e))


const f = payload => of(payload)
.pipe(
    delay(1000),
    // tap(e => console.info('before', e)),
    mergeMap(_ => from(p(payload))),
    // tap(e => console.info('after', e)),
    catchError(e => {

0

0

0

+ 2 other calls in file