An in-process and in-memory PubSub, Broadcast, EventBus or Fanout implementation with type-safe topics implemented with generics. Respects context.

A golang package which provides a fan out style reader writer pipe.

Buffered io.Pipe

Receive rtp packets from udp socket and send to subscribers

A lightweight event hub for Go with sync and async dispatch.

Fan Out design pattern (aka broadcasting channel using generics)

A simple Go package that implements a fanout pattern for channels.

ForkJoin implements a fork(fanout) and join(fanin) patterns using goroutines

This code was written for the Medium Article "Using Golang Fan-Out Concurrency Pattern for Splitting Stream by Keys"

Golang exercises

🔗 Streamline your Go applications with GSignal, a thread-safe Event Hub for efficient synchronous and asynchronous messaging between components.

Broadcast with fanout exchange.

📡 Publish and subscribe to messages in real time with this lightweight Go-based CLI, utilizing TCP for seamless topic management and delivery.

parallel executes any tasks in parallel by using Golang fanout fanin concurrency pattern

The fastest distributed system to monitor a power plant

A wrapper of zap supporting file rotating and more humanfriendly console output.

Topic based Subscription Feed

utility to enable flexible ETL scenarios, supports golang plug-in for built-in consumer|transformer|producer options

Repository for the coredns fanout plugin used by Network Service Mesh

A place to keep useful golang functions and small libraries