changes-stream
changes-stream copied to clipboard
jcrugzz
A fault tolerant changes stream for couchdb
The last published version v2.2.0 was pushed three years ago, 30/11/2016 - https://www.npmjs.com/package/changes-stream However, you have merged other changes since, more specifically the one where you upgraded packages - https://github.com/jcrugzz/changes-stream/commit/cbfd7d6c3a4e3e1f1be94c3c9afd5a3a2dfe98fd...
Since node v10, `ReadableStream`s are async-iterable, i.e. one can do the following: ```node for await (const chunk of readable) { data += chunk; } ``` See [the docs](https://nodejs.org/dist/latest/docs/api/stream.html#stream_readable_symbol_asynciterator) for more...
Having running watcher for a while I've got such errors in logs: ``` Error: socket hang up at createHangUpError (_http_client.js:323:15) at Socket.socketCloseListener (_http_client.js:364:25) at Socket.emit (events.js:194:15) at TCP._handle.close (net.js:597:12) code:...
I have created a PR (https://github.com/jcrugzz/changes-stream/pull/23) to reduce delay with parsing large documents. The current approach splits the entire document buffer after every append. The new approach splits each new...
For large documents (tens of MB), performance is quadratically slow because each small chunk of data triggers a `split`. This small fix dramatically improves performance for large documents.
The HTTP option Reject Unauthorized is always set to `true` regardless of values set for options `strictSSL` and `rejectUnauthorized` due to following code snippet: `this.rejectUnauthorized = options.strictSSL || options.rejectUnauthorized ||...
Hi there, How can I wrap stream errors with user facing error messages for instance when couch responds with something else than a `200`? (specifically in my case when a...
:wave: i am just saying hi and that i ported this to Rust in case ya'll were interested. thanks for a cool package! https://github.com/ashleygwilliams/changes-stream-rust
There are situations where folks proxy the CouchDB API or otherwise only expose parts of it--such as the changes feed--into their own API space. Since this library only (afaict) works...
