mediator

Documentation

Index

• Variables
• type Callback
• type Mediator
  • func NewMediator() Mediator

Variables

var Component = &app.Component{
	Constructor: func(container container.Container) error {
		return container.Provide(NewMediator)
	},
	Serve: func(c container.Container) error {
		closer, err := container.Get[closer.Closer](c)
		if err != nil {
			return err
		}

		ctx, cancelFunc := context.WithCancel(closer.GetContext())
		defer cancelFunc()

		<-ctx.Done()

		mediator, err := container.Get[Mediator](c)
		if err != nil {
			return err
		}

		return mediator.Close()
	},
}

Types

type Callback

type Callback func(data any)

type Mediator

type Mediator interface {
	io.Closer
	Subscribe(channel string, callback Callback)
	Send(channel string, data any)
}

func NewMediator

func NewMediator() Mediator