bus

Documentation

Index

• func Listen[T Event](ctx context.Context, example T) <-chan T
• func Next[T Event](input T)
• func Publish[T Event](event T)
• func Subscribe[T Event](ctx context.Context, fn func(T))
• type Event

Functions

func Listen

func Listen[T Event](ctx context.Context, example T) <-chan T

func Next

func Next[T Event](input T)

func Publish

func Publish[T Event](event T)

func Subscribe

func Subscribe[T Event](ctx context.Context, fn func(T))

Types

type Event

type Event any