nishimura.clubnishimura.club

RXJS

Syntax

import { interval, of } from 'rxjs'; import { map, take, concatMap } from 'rxjs/operators'; const randomString = () => Math.random().toString(36).slice(2); const source$ = interval(200).pipe( take(100), concatMap((i) => i % 10 === 0 ? of(`${randomString()}\n`) : of(randomString()) ) ); source$.subscribe(console.log);
import { interval, of } from 'rxjs'; import { map, take, concatMap } from 'rxjs/operators'; const randomString = () => Math.random().toString(36).slice(2); const source$ = interval(200).pipe( take(100), concatMap((i) => i === 99 ? of({ data: `${randomString()}\n` }) : of({ data: randomString() }) ) ); source$.subscribe(console.log);