eventsource

Overview ¶

Package eventsource provides a pubsub.Topic that also stores the last published value in an atomic.Value.

Updating the value will result in a publish event.

Example:

package main

import (
	"fmt"
	"time"

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

func main() {
	// Create a new event source.
	e := eventsource.New[int]()

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

	// Publish a value.
	e.Store(1)

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