client

livekit · Sep 21, 2024 · ce9e11c · ce9e11c
1 parent 55159f8
commit ce9e11c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git 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
@@ -43,3 +43,8 @@ func NewIngressClient(params ClientParams) (IngressClient, error) {
 		IngressHandlerClient:  handlerClient,
 	}, nil
 }
+
+func (c *ingressClient) Close() {
+	c.IngressInternalClient.Close()
+	c.IngressHandlerClient.Close()
+}