event_broker

package

v0.9.8-RC03 Latest Latest Go to latest Published: Oct 22, 2025 License: MIT Imports: 0 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broker[T any] struct {
	// contains filtered or unexported fields
}

func New[T any]() *Broker[T]

func (b *Broker[T]) Publish(msg T)

func (b *Broker[T]) Start()

func (b *Broker[T]) Stop()

func (b *Broker[T]) Subscribe() chan T

func (b *Broker[T]) Unsubscribe(msgCh chan T)

type IBroker interface {
	Start()
	Stop()
	Publish(any)
	Subscribe() chan any
}