parzh / observable-to-async-generator Goto Github PK

Hi. Found your lib useful while working with NestJS. I had to take data from microservice (which is received as an observable) and pass it as readable stream to front-end (kinda Readable.from(otag(observable))).

But i faced some issues when observable emits few values at once. In case I do

const observable = from([1,2,3]);
for await (const i of otag(observable)) {
  console.log(i)
}

I don't even hit that console.log.

• work is done mainly in feature/* branches (but it's not required)
• master branch is renamed to main, and it's the default branch
• pushing tags to main (git push --follow-tags) triggers a publish
• check package versions in package.json and package-lock.json match
• check version isn't published already (vacant)
• build and test right before publish
• test on linux, macos and windows