From a4aebd5d8824537b1de2a7e9888245ba98fe990c Mon Sep 17 00:00:00 2001
From: Daniel Liu <139250065@qq.com>
Date: Tue, 29 Apr 2025 17:07:10 +0800
Subject: [PATCH] rpc: fix typos (#1011)

---
 rpc/client.go       | 2 +-
 rpc/handler.go      | 4 ++--
 rpc/json.go         | 2 +-
 rpc/server.go       | 2 +-
 rpc/service.go      | 4 ++--
 rpc/subscription.go | 2 +-
 rpc/types.go        | 2 +-
 7 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/rpc/client.go b/rpc/client.go
index 773bd7eccd..70ad72e28d 100644
--- a/rpc/client.go
+++ b/rpc/client.go
@@ -70,7 +70,7 @@ type BatchElem struct {
 	// discarded.
 	Result interface{}
 	// Error is set if the server returns an error for this request, or if
-	// unmarshaling into Result fails. It is not set for I/O errors.
+	// unmarshalling into Result fails. It is not set for I/O errors.
 	Error error
 }
 
diff --git a/rpc/handler.go b/rpc/handler.go
index 238570cc4d..141ba6eeb0 100644
--- a/rpc/handler.go
+++ b/rpc/handler.go
@@ -324,7 +324,7 @@ func (h *handler) addRequestOp(op *requestOp) {
 	}
 }
 
-// removeRequestOps stops waiting for the given request IDs.
+// removeRequestOp stops waiting for the given request IDs.
 func (h *handler) removeRequestOp(op *requestOp) {
 	for _, id := range op.ids {
 		delete(h.respWait, string(id))
@@ -388,7 +388,7 @@ func (h *handler) startCallProc(fn func(*callProc)) {
 	}()
 }
 
-// handleResponse processes method call responses.
+// handleResponses processes method call responses.
 func (h *handler) handleResponses(batch []*jsonrpcMessage, handleCall func(*jsonrpcMessage)) {
 	var resolvedops []*requestOp
 	handleResp := func(msg *jsonrpcMessage) {
diff --git a/rpc/json.go b/rpc/json.go
index 5557a80760..e932389d17 100644
--- a/rpc/json.go
+++ b/rpc/json.go
@@ -266,7 +266,7 @@ func (c *jsonCodec) close() {
 	})
 }
 
-// Closed returns a channel which will be closed when Close is called
+// closed returns a channel which will be closed when Close is called
 func (c *jsonCodec) closed() <-chan interface{} {
 	return c.closeCh
 }
diff --git a/rpc/server.go b/rpc/server.go
index af599a6b94..270e7a63fa 100644
--- a/rpc/server.go
+++ b/rpc/server.go
@@ -88,7 +88,7 @@ func (s *Server) SetHTTPBodyLimit(limit int) {
 }
 
 // RegisterName creates a service for the given receiver type under the given name. When no
-// methods on the given receiver match the criteria to be either a RPC method or a
+// methods on the given receiver match the criteria to be either an RPC method or a
 // subscription an error is returned. Otherwise a new service is created and added to the
 // service collection this server provides to clients.
 func (s *Server) RegisterName(name string, receiver interface{}) error {
diff --git a/rpc/service.go b/rpc/service.go
index 43fa2a1a58..3530f47320 100644
--- a/rpc/service.go
+++ b/rpc/service.go
@@ -110,7 +110,7 @@ func (r *serviceRegistry) subscription(service, name string) *callback {
 }
 
 // suitableCallbacks iterates over the methods of the given type. It determines if a method
-// satisfies the criteria for a RPC callback or a subscription callback and adds it to the
+// satisfies the criteria for an RPC callback or a subscription callback and adds it to the
 // collection of callbacks. See server documentation for a summary of these criteria.
 func suitableCallbacks(receiver reflect.Value) map[string]*callback {
 	typ := receiver.Type()
@@ -227,7 +227,7 @@ func isSubscriptionType(t reflect.Type) bool {
 	return t == subscriptionType
 }
 
-// isPubSub tests whether the given method has as as first argument a context.Context and
+// isPubSub tests whether the given method's first argument is a context.Context and
 // returns the pair (Subscription, error).
 func isPubSub(methodType reflect.Type) bool {
 	// numIn(0) is the receiver type
diff --git a/rpc/subscription.go b/rpc/subscription.go
index 9cb0727547..cf296566c0 100644
--- a/rpc/subscription.go
+++ b/rpc/subscription.go
@@ -97,7 +97,7 @@ func NotifierFromContext(ctx context.Context) (*Notifier, bool) {
 	return n, ok
 }
 
-// Notifier is tied to a RPC connection that supports subscriptions.
+// Notifier is tied to an RPC connection that supports subscriptions.
 // Server callbacks use the notifier to send notifications.
 type Notifier struct {
 	h         *handler
diff --git a/rpc/types.go b/rpc/types.go
index 04d1214e16..f7e8e4b867 100644
--- a/rpc/types.go
+++ b/rpc/types.go
@@ -38,7 +38,7 @@ type API struct {
 }
 
 // ServerCodec implements reading, parsing and writing RPC messages for the server side of
-// a RPC session. Implementations must be go-routine safe since the codec can be called in
+// an RPC session. Implementations must be go-routine safe since the codec can be called in
 // multiple go-routines concurrently.
 type ServerCodec interface {
 	peerInfo() PeerInfo