fix grpc client warn when use streaming grpc interface

Signed-off-by: aoiasd <[email protected]>

internal/util/grpcclient/client.go

@@ -504,6 +504,9 @@ func (c *ClientBase[T]) call(ctx context.Context, caller func(client T) (any, er
 			status = res
 		case interface{ GetStatus() *commonpb.Status }:
 			status = res.GetStatus()
+		// streaming call
+		case grpc.ClientStream:
+			status = merr.Status(nil)
 		default:
 			// it will directly return the result
 			log.Warn("unknown return type", zap.Any("return", ret))

internal/util/grpcclient/client_test.go

@@ -39,6 +39,7 @@ import (
 	"github.com/milvus-io/milvus-proto/go-api/v2/milvuspb"
 	"github.com/milvus-io/milvus/internal/proto/rootcoordpb"
 	"github.com/milvus-io/milvus/internal/util/sessionutil"
+	"github.com/milvus-io/milvus/internal/util/streamrpc"
 	"github.com/milvus-io/milvus/pkg/util/merr"
 	"github.com/milvus-io/milvus/pkg/util/paramtable"
 	"github.com/milvus-io/milvus/pkg/util/typeutil"
@@ -170,6 +171,14 @@ func testCall(t *testing.T, compressed bool) {
 		assert.NoError(t, err)
 	})
 
+	t.Run("Call with stream method", func(t *testing.T) {
+		initClient()
+		_, err := base.Call(context.Background(), func(client *mockClient) (any, error) {
+			return streamrpc.LocalQueryClient{}, nil
+		})
+		assert.NoError(t, err)
+	})
+
 	t.Run("Call with canceled context", func(t *testing.T) {
 		initClient()
 		ctx, cancel := context.WithCancel(context.Background())