A helper tool for decoding MongoDB change stream resume tokens

A reusable MongoDB Change Stream manager

React integration for @rindle/narrator: subscribe to a Rindle query's netted change stream and buffer agent-ready semantic events.

n8n-nodes-mongo-change-stream-trigger is a community package for n8n that brings real-time MongoDB integration to your workflows. It uses MongoDB’s native change streams to monitor a specified collection without relying on polling and offers advanced, cas

A small, durable, Mongo-backed job queue — atomic claim, retries, visibility-timeout leases, dedupe keys, and change-stream push.

Standalone MongoDB change-stream watcher for cache-coherence: catches writes from any source, including ones that never touch the app's own Mongoose model.

MongoDB change stream invalidation for SafeCache.

Turn a Rindle view's netted flat-change stream into agent-ready prose: resolve each FlatChange to named rows (via @rindle/client), render per-query templates (root + nested relationships) into salience-tagged SemanticEvents, and digest a batch into a rank

a mongoose model generator with a change stream

Structural cache invalidation for Mongoose: write hooks that keep a two-tier cache honest, with a companion change-stream watcher for writes the hooks never see.

当前监听mongodb的change stream https://www.mongodb.com/docs/manual/changeStreams/ 来实时处理数据

MongoDB Change Stream watcher helper for distributed mutex and pubsub systems

ByteStream is a library making possible to manipulates single bytes and bits on pure JavaScript

Turn any MongoDB Change Stream into an async iterator.

Big-friendly JSON. Asynchronous streaming functions for large JSON data sets.

Node.js Streams, a user-land copy of the stream library from Node.js

Check if something is a Node.js stream

Get a stream as a string, Buffer, ArrayBuffer or array

write database transaction to elastic within change stream event

Call a callback when a readable/writable/duplex stream has completed or failed.