Convert an observable to ES6 async generator.
import otag from "observable-to-async-generator";
const otag = require("observable-to-async-generator").default;
try {
for await (const item of otag(observable))
doSomethingWith(item);
}
catch (error) {
handle(error);
}
rxjs@6
is a peer dependency for this package; it is primarily used to add types on the development stage. These type imports are removed from the JavaScript output, but are still present in*.d.ts
files; in case if the type information is needed,rxjs@6
should be installed manually.