A portable MQTT C client for embedded systems and PCs alike.

Monad, Functional Programming features for Golang

C# 事件总线实现

Monad/MonadIO, Handler, Coroutine/doNotation, Functional Programming features for Rust

Python Design Patterns

💬 Publish-Subscribe (a.k.a Pub/Sub, EventBus) library for Android and JVM built with Coroutines

Functional Programming for EcmaScript(Javascript)

Want to handle 100,000 messages in 90 seconds? Celery and Kombu are that awesome - Multiple publisher-subscriber demos for processing json or pickled messages from Redis, RabbitMQ or AWS SQS. Includes Kombu message processors using native Producer and Consumer classes as well as ConsumerProducerMixin workers for relay publish-hook or caching

A pub/sub architecture genetically engineered to make your project simpler, not more complicated. And to be adorable.

A compile-time header-only C++17 library for dataflow programing.

Library for state synchronization

A simple demo for showing how to interact with action lib in Python 2.7

NiFi processor emulating queue/topic patterns on top of Redis

A lightweight .NET standard messaging library for easily deal with any message broker, like RabbitMQ, ActiveMQ, AmazonSQS, AzureQueue, ...

An open source implementation of Apple's Combine framework for processing asynchronous events over time

Simple implementation of Publisher/Subscriber pattern in typescript

Error handling in Combine

Fantastic love story between NodeJS and MQTT

This is a php wrapper built on top of php-amqplib (@videlalvaro).

Python nodes to publish/subscribe RGB-D images and their point clouds (or any of them) to/from ROS topics.

Simple, publisher-subscriber based service registry for service discovery and dynamic configuration update, developed with Go

An opinionated approach to use Apache Kafka in Dotnet

Publisher - Subscriber on top of a self-routing node network (C++ 14)

An application to perform edge analytics on IoT sensor devices with Apache Edgent.

A set of classes and modules for .Net development

Longsword Web Socket Server Working demo: https://www.youtube.com/watch?v=v7hvOyPQ0EM Longsword Web Socket Server: Provides live sensor data feed, stance classification view & scores/confidence %. The web-page is being served by node-js. An active web-socket connection is being mainted with the RESTful deep learning model service. The messages push real-time data and classification results to the web page's graphs.

Extra reactor utils that aren't included in either core or addons

C++ Type-based Subscriber-Publisher data-oriented scheduling model with minimal-to-no overhead

Rudra-EventDispatcher

Video streaming in groups