Files

10 lines
246 B
JavaScript

const { Observable, Subject, ReplaySubject, from, of, range } = require('rxjs')
const { map, filter, switchMap } = require('rxjs/operators')
range(1, 200)
.pipe(
filter((x) => x % 2 === 1),
map((x) => x + x)
)
.subscribe((x) => x)