S3 Tables: fix gRPC stream loop handling for list operations

- Correctly handle io.EOF to terminate loops gracefully.
- Propagate other errors to prevent silent failures.
- Ensure all list results are processed effectively.

weed/s3api/s3tables/handler_bucket_get_list_delete.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 	"net/http"
 	"strings"
 
@@ -106,8 +107,11 @@ func (h *S3TablesHandler) handleListTableBuckets(w http.ResponseWriter, r *http.
 			for {
 				entry, respErr := resp.Recv()
 				if respErr != nil {
+					if respErr == io.EOF {
 						break
 					}
+					return respErr
+				}
 				if entry.Entry == nil {
 					continue
 				}
@@ -219,8 +223,11 @@ func (h *S3TablesHandler) handleDeleteTableBucket(w http.ResponseWriter, r *http
 		for {
 			entry, err := resp.Recv()
 			if err != nil {
+				if err == io.EOF {
 					break
 				}
+				return err
+			}
 			if entry.Entry != nil && !strings.HasPrefix(entry.Entry.Name, ".") {
 				hasChildren = true
 				break

weed/s3api/s3tables/handler_table.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io"
 	"net/http"
 	"strings"
 	"time"
@@ -338,8 +339,11 @@ func (h *S3TablesHandler) listTablesInNamespaceWithClient(ctx context.Context, c
 		for {
 			entry, respErr := resp.Recv()
 			if respErr != nil {
+				if respErr == io.EOF {
 					break
 				}
+				return respErr
+			}
 			if entry.Entry == nil {
 				continue
 			}
@@ -415,8 +419,11 @@ func (h *S3TablesHandler) listTablesInAllNamespaces(ctx context.Context, filerCl
 			for {
 				entry, respErr := resp.Recv()
 				if respErr != nil {
+					if respErr == io.EOF {
 						break
 					}
+					return respErr
+				}
 				if entry.Entry == nil {
 					continue
 				}