bus

type EmptySubscription[MessageType any] struct{}

type MessageBus interface {
	Publish(ctx context.Context, channel string, msg proto.Message) error
	Subscribe(ctx context.Context, channel string, channelSize int) (Reader, error)
	SubscribeQueue(ctx context.Context, channel string, channelSize int) (Reader, error)
}

type PublishHandler func(ctx context.Context, channel string, msg proto.Message) error

type PublishInterceptor func(next PublishHandler) PublishHandler

type ReadHandler func() ([]byte, bool)

type Reader interface {
	Close() error
	// contains filtered or unexported methods
}

type SubscribeInterceptor func(ctx context.Context, channel string, next ReadHandler) ReadHandler

type Subscription[MessageType proto.Message] interface {
	Channel() <-chan MessageType
	Close() error
}

type TestBusOption func(*TestBusOpts)

type TestBusOpts struct {
	PublishInterceptors   []PublishInterceptor
	SubscribeInterceptors []SubscribeInterceptor
}