Broadcast

A small utility that allows you to distribute messages to groups of long-lived connections. The implementation is connection ignorant so it could be used with different communication mechanisms like web sockets and gRPC server streams.

Installation

go get github.com/go-broadcast/broadcast

Basic usage

import (
	"log"
	"time"

	"github.com/go-broadcast/broadcast"
)

func main() {
	broadcaster, cancel, err := broadcast.New()
	if err != nil {
		log.Fatal(err)
	}

	subscription := broadcaster.Subscribe(func(data interface{}) {
		log.Printf("Received message: %v", data)
	})

	broadcaster.JoinRoom(subscription, "chat-room")
	broadcaster.ToRoom("Hello, chat!", "chat-room")

	<-time.After(time.Second * 10)

	broadcaster.ToRoom("Bye, chat!", "chat-room")
	broadcaster.Unsubscribe(subscription)

	cancel()
	<-broadcaster.Done()
}

More examples

• Web sockets
• gRPC server streams
• Scale out with Redis