Rename Consume to NewRPC

TimeleapLabs · Apr 8, 2024 · 049c383 · 049c383
1 parent f2bed6d
commit 049c383
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/internal/cmd/consumer.go b/internal/cmd/consumer.go
@@ -55,7 +55,7 @@ var consumerCmd = &cobra.Command{
 		conn.Start()
 
 		handler := handler.NewConsumerHandler(correctnessService, uniswapService, evmLogService)
-		client.Consume(handler)
+		client.NewRPC(handler)
 
 		server.New(
 			gql.WithGraphQL(),

diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go
@@ -57,7 +57,7 @@ var workerCmd = &cobra.Command{
 		conn.Start()
 
 		handler := handler.NewWorkerHandler()
-		client.Consume(handler)
+		client.NewRPC(handler)
 
 		scheduler.Start()
 	},

diff --git a/internal/transport/client/client.go b/internal/transport/client/client.go
@@ -7,7 +7,7 @@ import (
 	"github.com/KenshiTech/unchained/transport/client/handler"
 )
 
-func Consume(handler handler.Handler) {
+func NewRPC(handler handler.Handler) {
 	incoming := conn.Read()
 
 	go func() {