async-iterator-from-rx

A tool to convert RxJS style observable stream asyncGenerator.

Motivation

RxJS is not so common compare with async/await and it's hard to learn. This tool can help user who is not so familiar with observable to use observables in async/await way.

Install

npm i -S rx-from-async-iterator tslib rxjs

Example

Simple usage

For example, we need to collect 10 user touch points when in some case. And we've already have a click stream. Use asyncIteratorFromRx to convert stream to asyncIterator so that you can use for await ... of syntax to process the stream signal.

1import { asyncIteratorFromRx } from "async-iterator-from-rx";
2import { fromEvent } from "rxjs";
3
4const click$ = fromEvent("pointerdown", document.body); // A click stream.
5
6async function batchCollectByCount(count: number) {
7  const clickTrace: Array<[x: number, y: number]> = [];
8  const clickIterator = asyncIteratorFromRx(click$); // Convert click stream to an asyncIterator
9  for await (const evt of clickIterator) {
10    // use `for await ... of` to scan the click stream
11    clickTrace.push([evt.x, evt.y]);
12    if (clickTrace.length === count) {
13      break;
14    }
15  }
16  return clickTrace;
17}
18
19batchCollectByCount(10).then(uploadClickTrace);