pubsub

type PubSub interface {
	Topic(name string) Topic
}

type Subscription interface {
	io.Closer
	Next() []byte
}

type Topic interface {
	Publish(ctx context.Context, data []byte)
	Subscribe(ctx context.Context) Subscription
}