From a6bfff28eed6f894f1befc2e6397f904f578400e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Friedemann=20F=C3=BCrst?=
 <59653747+friedemannf@users.noreply.github.com>
Date: Wed, 27 May 2026 20:17:19 +0200
Subject: [PATCH] EDS - Add CloseSend call to BackfilledStream

---
 eds/internal/store/stream.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/eds/internal/store/stream.go b/eds/internal/store/stream.go
index b7f77489f..747d8cfea 100644
--- a/eds/internal/store/stream.go
+++ b/eds/internal/store/stream.go
@@ -282,6 +282,10 @@ func ReceiveFromStream[T any](ctx context.Context, stream grpc.ServerStreamingCl
 	go func() {
 		defer close(respChan)
 		defer close(errChan)
+		defer func(stream grpc.ServerStreamingClient[T]) {
+			// CloseSend always returns a nil error.
+			_ = stream.CloseSend()
+		}(stream)
 
 		for {
 			resp, err := stream.Recv()