eventbus

Documentation

Index

• func Publish[T any](topic string, data T)
• func Subscribe[T any](topic string, fn func(data T))
• type Bus

Functions

func Publish

func Publish[T any](topic string, data T)

func Subscribe

func Subscribe[T any](topic string, fn func(data T))

Types

type Bus

type Bus[T any] struct {
	Topic string
	Subs  map[string][]chan T
	// contains filtered or unexported fields
}