rx-to-iterall
所属分类：网络编程
开发工具：JavaScript
文件大小：0KB
下载次数：0
上传日期：2023-03-01 18:30:09
上 传 者：
sh-1993
说明： 将rxjs观察值转换为迭代器异步迭代器，
(Convert rxjs observables into iterall async iterators,)
文件列表:
.travis.yml (52, 2018-07-01)
LICENSE (1069, 2018-07-01)
__tests__/ (0, 2018-07-01)
__tests__/__snapshots__/ (0, 2018-07-01)
__tests__/__snapshots__/rxjs-to-iterall.test.js.snap (15371, 2018-07-01)
__tests__/rxjs-to-iterall.test.js (5991, 2018-07-01)
index.js (2733, 2018-07-01)
package-lock.json (248549, 2018-07-01)
package.json (912, 2018-07-01)
# rx-to-iterall [](https://travis-ci.org/tjmehta/rx-to-iterall)
[](https://greenkeeper.io/)
Convert rxjs Observables into iterall AsyncIterators
# Installation
```bash
npm i --save rx-to-iterall
```
# Usage
Convert an rxjs Observable into an iterall AsyncIterator
```js
const forAwaitEach = require('iterall').forAwaitEach
const Observable = require('rxjs').Observable
const rxjsToIterall = require('rx-to-iterall')
const observable = Observable.from([1, 2, 3])
const asyncIterator = rxjsToIterall(observable)
const results = []
await forAwaitEach(asyncIterator, (data) => {
results.push(data)
})
console.log(results) // [1, 2, 3] (observable values)
```
Extend ObservableAsyncIterator with custom behavior
```js
const ObservableAsyncIterator = require('rx-to-iterall')
class FooAsyncIterator extends ObservableAsyncIterator {
// ...
}
```
# License
MIT
近期下载者：
相关文件：
收藏者：