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 Reader interface {
	Close() error
	// contains filtered or unexported methods
}

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