func WithStreaming(clusterID, clientID string) Option {
	return func(o *Options) {
		o.UseStreaming = true
		o.StreamingClientID = clientID
		o.StreamingClusterID = clusterID
	}
}
WithStreaming is an Option to activate nats streaming for the transport.
package nats
import "github.com/nats-io/go-nats"
type Options struct {
	Conn               *nats.Conn
	StreamingClusterID string
	StreamingClientID  string
	UseStreaming       bool
}
type Option func(*Options)
func WithConnection(c *nats.Conn) Option {
	return func(o *Options) {
		o.Conn = c
	}
}