event

var (
	// ErrEventBusAlreadyStarted indicates event bus already started.
	ErrEventBusAlreadyStarted = errors.New("event bus already started")
	// ErrShutdownTimeoutExceeded indicates shutdown wait timeout.
	ErrShutdownTimeoutExceeded = errors.New("shutdown timeout exceeded")
)

var (
	Module = fx.Module(
		"vef:event",
		fx.Provide(
			fx.Annotate(
				createMemoryBus,
				fx.ParamTags(``, `group:"vef:event:middlewares"`),
				fx.As(fx.Self()),
				fx.As(new(event.Subscriber)),
				fx.As(new(event.Publisher)),
			),
		),
	)
)