A comunica bus for sparql-parse events.
A qpf query-source-identify-hypermedia actor
OpenTelemetry instrumentation for @powerhousedao/reactor
Simple TS event bus
yocto-queue package exported as CommonJS modules
Distributed Command Bus library with Redis Streams transport, MessagePack serialization, and RPC via LPUSH/BRPOP for DragonflyDB
A comunica bus for query-source-dereference-link events.
A filter query-operation actor
A join-coefficients-fixed mediator
A really simple message queue based on Redis
A comunica bus for query-serialize events.
A redis transport adapter for @node-ts/bus-core.
Local development World implementation for Workflow SDK
A comunica bus for sparql-serialize events.
The next great DBus library for Node
A mediator for a single mediation number value
Job manager
Queue abstraction for the Celerity Node SDK (SQS / Pub/Sub / Service Bus)
Serial queue module.
A wrapper-limit-count rdf-resolve-hypermedia-links-queue actor
Basic AdonisJS queue provider
A proxy http actor
A simple queue interface with support for multiple backends
Distributed messaging in Typescript