Package Exports

rx-to-iterall

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (rx-to-iterall) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

rx-to-iterall

Convert rxjs Observables into iterall AsyncIterators

Installation

npm i --save rx-to-iterall

Usage

Convert an rxjs Observable into an iterall AsyncIterator

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

const ObservableAsyncIterator = require('rx-to-iterall')

class FooAsyncIterator extends ObservableAsyncIterator {
  // ...
}

License

MIT