pubsub

Overview ¶

Package pubsub provides a simple publish/subscribe mechanism.

Example:

package main

import (
	"fmt"
	"time"

	"github.com/alecthomas/types/pubsub"
)

func main() {
	// Create a new topic.
	t := pubsub.New[int]()

	// Subscribe to changes.
	changes := t.Subscribe(nil)
	go func() {
		for change := range changes {
			fmt.Println("change:", change)
		}
	}()

	// Publish a value.
	t.Publish(1)

	// Publish a value and wait for it to be received.
	t.Publish(2)
	time.Sleep(time.Millisecond)
}