highland
highland copied to clipboard
caolan
High-level streams library for Node.js and the browser
Hi! I've been introducing highland into a Node project at work, and I've noticed that I get warnings from node in certain conditions. Specifically, when I run this snippet: ```javascript...
It is absolutely trivial to use thew worker threads feature in Node with Highland. I'm not sure if this should be part of core but at the very least I...
Stream.scan(memo, iterator) looks like memo is forced to accept string and buffer, any suggestion or work around to make "memo" accept an array
When consuming a stream with [`.reduce`](https://caolan.github.io/highland/#reduce), I'd like to be able to do some async operations inside the `iterator/reducer` function and have the stream wait for their completion before consuming...
The following test deadlocks (`toCallback` never gets called): ```js /* eslint-disable no-unused-vars, no-shadow, no-redeclare */ var _, EventEmitter = require('events').EventEmitter, through = require('through'), // sinon = require('sinon'), Stream = require('stream'),...
Hi good day, I've a class named RPC, here we've this method ```ts public async send(nber : number) : Promise { if (!this.stream) { await this.delay(2); console.info('RPC not initialized yet...retrying');...
Wasted a good deal of my time trying to figure out why `parallel` was not performing as efficiently as I expected. Hopefully this will save others from the same tar...
I found Highland while searching for stream library support for native JS async generators (like `async function *main(..) { .. }`) and thus async-iteration. It seems from looking at the...
Calling `src.destroy()` in a `stopOnError` callback errors with `Cannot write to stream after nil`. ```js const nodeReadableStream = createNodeReadableStream(); const src = _(nodeReadableStream, () => () => nodeReadableStream.destroy()); src .map((msg)...
Hi! Is it possible to get an async iterable from a highland object? I'd like to be able to consume it with for-await-of if possible.
