From 049c3832fcdc7ce1cbc004fdf1e6556e795033c9 Mon Sep 17 00:00:00 2001
From: Pouya <pouya@kenshi.io>
Date: Mon, 8 Apr 2024 11:09:14 +0200
Subject: [PATCH] Rename Consume to NewRPC

---
 internal/cmd/consumer.go            | 2 +-
 internal/cmd/worker.go              | 2 +-
 internal/transport/client/client.go | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/internal/cmd/consumer.go b/internal/cmd/consumer.go
index cfc0a372..9431503e 100644
--- 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
index bf62b268..0ce67271 100644
--- 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
index 096cb170..291c5f07 100644
--- 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() {