From ce9e11cec8eb5d89a26dc34d8632fa6f9ce2d1c9 Mon Sep 17 00:00:00 2001
From: Paul Wells <paulwe@gmail.com>
Date: Fri, 20 Sep 2024 23:44:20 -0700
Subject: [PATCH] client

---
 rpc/egress_client.go  | 5 +++++
 rpc/ingress_client.go | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/rpc/egress_client.go b/rpc/egress_client.go
index db7707c9..7125d385 100644
--- a/rpc/egress_client.go
+++ b/rpc/egress_client.go
@@ -109,3 +109,8 @@ func (c *egressClient) StartEgress(ctx context.Context, topic string, req *Start
 	}, opts...)
 	return c.EgressInternalClient.StartEgress(ctx, topic, req, o...)
 }
+
+func (c *egressClient) Close() {
+	c.EgressInternalClient.Close()
+	c.EgressHandlerClient.Close()
+}
diff --git a/rpc/ingress_client.go b/rpc/ingress_client.go
index 7e2c1688..88b20d66 100644
--- a/rpc/ingress_client.go
+++ b/rpc/ingress_client.go
@@ -43,3 +43,8 @@ func NewIngressClient(params ClientParams) (IngressClient, error) {
 		IngressHandlerClient:  handlerClient,
 	}, nil
 }
+
+func (c *ingressClient) Close() {
+	c.IngressInternalClient.Close()
+	c.IngressHandlerClient.Close()
+}