Merge pull request #1013 from jafossum/fix-nats-typos

Fix docstring typos in nats and jetstream protocol

protocol/nats/v2/options.go

@@ -13,8 +13,8 @@ import (
 
 var ErrInvalidQueueName = errors.New("invalid queue name for QueueSubscriber")
 
-// NatsOptions is a helper function to group a variadic stan.ProtocolOption into
-// []stan.Option that can be used by either Sender, Consumer or Protocol
+// NatsOptions is a helper function to group a variadic nats.ProtocolOption into
+// []nats.Option that can be used by either Sender, Consumer or Protocol
 func NatsOptions(opts ...nats.Option) []nats.Option {
 	return opts
 }

protocol/nats/v2/protocol.go

@@ -24,7 +24,7 @@ type Protocol struct {
 	Sender        *Sender
 	senderOptions []SenderOption
 
-	connOwned bool // whether this protocol created the stan connection
+	connOwned bool // whether this protocol created the nats connection
 }
 
 // NewProtocol creates a new NATS protocol.

protocol/nats/v2/sender.go

@@ -22,7 +22,7 @@ type Sender struct {
 	connOwned bool
 }
 
-// NewSender creates a new protocol.Sender responsible for opening and closing the STAN connection
+// NewSender creates a new protocol.Sender responsible for opening and closing the NATS connection
 func NewSender(url, subject string, natsOpts []nats.Option, opts ...SenderOption) (*Sender, error) {
 	conn, err := nats.Connect(url, natsOpts...)
 	if err != nil {
@@ -40,7 +40,7 @@ func NewSender(url, subject string, natsOpts []nats.Option, opts ...SenderOption
 	return s, nil
 }
 
-// NewSenderFromConn creates a new protocol.Sender which leaves responsibility for opening and closing the STAN
+// NewSenderFromConn creates a new protocol.Sender which leaves responsibility for opening and closing the NATS
 // connection to the caller
 func NewSenderFromConn(conn *nats.Conn, subject string, opts ...SenderOption) (*Sender, error) {
 	s := &Sender{

protocol/nats_jetstream/v2/sender.go

@@ -42,7 +42,7 @@ func NewSender(url, stream, subject string, natsOpts []nats.Option, jsmOpts []na
 	return s, nil
 }
 
-// NewSenderFromConn creates a new protocol.Sender which leaves responsibility for opening and closing the STAN
+// NewSenderFromConn creates a new protocol.Sender which leaves responsibility for opening and closing the NATS
 // connection to the caller
 func NewSenderFromConn(conn *nats.Conn, stream, subject string, jsmOpts []nats.JSOpt, opts ...SenderOption) (*Sender, error) {
 	jsm, err := conn.JetStream(jsmOpts...)