@thi.ng/csp
Primitives & operators for Communicating Sequential Processes based on async/await and async iterables
Primitives & operators for Communicating Sequential Processes based on async/await and async iterables
Google Cloud PubSub wrapper
Redis backend engine for Faye
A tiny (less than 1k) event emitter library
A micro-servicebus for RabbitMQ
Realtime apps with a high level API based on engine.io
micro pubsub library
A base plugin for federating instances of postal.js across various boundaries.
Node-RED nodes for Google Cloud Platform
postal.js/postal.federation plugin for federating instances of postal.js across iframe/window boundaries.
A libp2p module that uses pubsub for mdns like peer discovery
Pub/Sub service for Angular (7-17)
Node.js unicast discovery, master-slave elections and pub/sub.
Lightweight wrapper for typed PubSub events
PubSub for Node and the Browser.
PubSub service based on RxJs ReplaySubject
A plugin for the Serverless framework that enables easier configuration for publish/subscribe pattern
Wrapper around amqp to make common patterns easier
Creates distributed callback queue based on redis pubsub. Pass 2 redis clients (supports redis sentinel as well for HA), manages locks across multiple processes
NestJS Postgres pubsub module