mb

type PubOpts func(o *options)

type Publisher interface {
	Publish(stream, subj string, sender interface{}, o ...PubOpts) (interface{}, error)
}

type SubRec func(o *options)

type Subscriber interface {
	Delivery(receivers ...SubRec) error

	Subscribe(stream, subj, cons string, cmd endpoint.Endpoint) SubRec

	Close() error
}