xsrx

Pipeable operators for xstream, with rxjs compatibility layer.

Reason: Being an avid rxjs user I want to be able to use xstream's hot streams without having to "switch" to a different syntax. As a bonus: if I ever want to refactor to rxjs I'd only have to replace the imports.

NOTE: Does NOT convert from xstream to rxjs, so even though you wouldn't have to go through all your codebase to change operator names and from dot[.]chaining to piping, you might still have to deal with the fact that you're switching from hot to cold observables.

TL;DR

1xs.periodic(1000)
2  .mapTo(1)
3  .fold((acc, c) => acc + c, 1)
4  .map(id =>
5    xs.from(
6      fetch(`https://swapi.dev/api/people/${id}`).then(res => res.json()),
7    ),
8  )
9  .flatten()
10  .map(data => data.name)
11
12// to
13interval(1000).pipe(
14  mapTo(1),
15  scan((acc, c) => acc + c, 1),
16  switchMap(id =>
17    from(fetch(`https://swapi.dev/api/people/${id}`).then(res => res.json())),
18  ),
19  pluck('name'),
20)
21
22// or using the pipeline operator
23// https://github.com/tc39/proposal-pipeline-operator
24interval(1000)
25  |> mapTo(1)
26  |> scan((acc, c) => acc + c, 1)
27  |> switchMap(id =>
28    from(fetch(`https://swapi.dev/api/people/${id}`).then(res => res.json())),
29  )
30  |> pluck('name')
31
32// and it's still an `xstream` Stream

Imports are the same as in rxjs

1import { interval } from 'xs.rx'
2import { mapTo, scan, switchMap, pluck } from 'xs.rx/operators'