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

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

Python Design Patterns

⚙ Generic Unity event system (event bus pattern)

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

Simple examples of object oriented design.

A set of classes and modules for .Net development

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

todo app example express.js implementation custom pub/sub using bullmq and redis

C++ utility class allowing subscribing to changes of particular members (properties) of a class (=Observer pattern simplified). Works well with UI properties that can only be updated on the GUI thread. C++ equivalent of Android's LiveData.

Lightweight library based on RabbitMQ.Client that brings simpliness to configure RabbitMQ client in ASP.NET Core with Dependency Injection support.

NiFi processor emulating queue/topic patterns on top of Redis

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

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

ROS 2 Project Builder is a CLI-based tool that automates the creation of ROS 2 packages and node structures. It supports both Python and C++, enabling fast generation of publishers, subscribers, services, actions, and more with customizable QoS and clean, modular code templates.

Event publisher/subscriber library

Gin and GraphQL server using Golang, gorm, gqlgen.

An opinionated approach to use Apache Kafka in Dotnet

Real-Time collaborative todo example by using HPKV

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

📻 Lightweight & Reliable MongoDB Pub/Sub Messenger

Library for state synchronization

MVC-Actors: LabVIEW Actor Framework extension implementing Model-View-Controller patterns with bidirectional event publisher/subscriber mechanism and GUI management tools.

A simple message-broker/Pub-sub library

A ROS2 Humble–based autonomous robot navigation system demonstrating node-based architecture, topic communication, and reactive obstacle avoidance using Python.

FAST DDS demo based on the tutorial