events

Documentation

Index

• type EventEmitter
• type EventSubscriber
• type Topic
  • func NewTopic[E any](bufferSize ...int) Topic[E]

Types

type EventEmitter

type EventEmitter[E any] interface {
	Emit(ctx context.Context, event E)
}

type EventSubscriber

type EventSubscriber[E any] interface {
	Subscribe(id string) <-chan E
}

type Topic

type Topic[E any] interface {
	EventEmitter[E]
	EventSubscriber[E]
}

func NewTopic

func NewTopic[E any](bufferSize ...int) Topic[E]

NewTopic creates a new topic with an optional buffer size Omiting the buffer size will create an unbuffered topic