Fix some typos.

encoders/builtin/default_enc.go

@@ -24,7 +24,7 @@ import (
 // DefaultEncoder implementation for EncodedConn.
 // This encoder will leave []byte and string untouched, but will attempt to
 // turn numbers into appropriate strings that can be decoded. It will also
-// propely encoded and decode bools. If will encode a struct, but if you want
+// properly encoded and decode bools. If will encode a struct, but if you want
 // to properly handle structures you should use JsonEncoder.
 type DefaultEncoder struct {
 	// Empty

example_test.go

@@ -612,7 +612,7 @@ func ExampleSubOpt() {
 		nats.MaxDeliver(1),
 		// Activate Flow control algorithm from the server.
 		nats.EnableFlowControl(),
-		// Track heartbeats from the server fro missed sequences.
+		// Track heartbeats from the server for missed sequences.
 		nats.IdleHeartbeat(500*time.Millisecond),
 	)
 

jetstream/stream_config.go

@@ -123,7 +123,7 @@ type (
 		//
 		// If set to true, publish methods from the JetStream client will not
 		// work as expected, since they rely on acknowledgements. Core NATS
-		// publish methods should be used instead. Note tha this will make
+		// publish methods should be used instead. Note that this will make
 		// message delivery less reliable.
 		NoAck bool `json:"no_ack,omitempty"`
 

micro/test/service_test.go

@@ -181,7 +181,7 @@ func TestServiceBasics(t *testing.T) {
 
 	// Services should process 50 requests total
 	if requestsNum != 50 {
-		t.Fatalf("Expected a total fo 50 requests processed, got: %d", requestsNum)
+		t.Fatalf("Expected a total of 50 requests processed, got: %d", requestsNum)
 	}
 	// Reset stats for a service
 	svcs[0].Reset()

object.go

@@ -384,7 +384,7 @@ func (obs *obs) Put(meta *ObjectMeta, r io.Reader, opts ...ObjectOpt) (*ObjectIn
 		case <-time.After(obs.js.opts.wait):
 		}
 		if err := obs.js.purgeStream(obs.stream, &StreamPurgeRequest{Subject: chunkSubj}); err != nil {
-			return fmt.Errorf("could not cleanup bucket after erronous put operation: %w", err)
+			return fmt.Errorf("could not cleanup bucket after erroneous put operation: %w", err)
 		}
 		return nil
 	}

test/conn_test.go

@@ -2890,7 +2890,7 @@ func TestTLSHandshakeFirst(t *testing.T) {
 	tlsConf.ServerName = "localhost"
 
 	// Start a mockup server that will do the TLS handshake first
-	// and then send the INFO protcol.
+	// and then send the INFO protocol.
 	l, e := net.Listen("tcp", ":0")
 	if e != nil {
 		t.Fatal("Could not listen on an ephemeral port")

test/js_test.go

@@ -8622,7 +8622,7 @@ func TestJetStreamMsgSubjectRewrite(t *testing.T) {
 		t.Fatalf("Subject should be %q, got %q", "foo", msg.Subject)
 	}
 	if string(msg.Data) != "msg" {
-		t.Fatalf("Unexepcted data: %q", msg.Data)
+		t.Fatalf("Unexpected data: %q", msg.Data)
 	}
 }