From 4675b65476a7e78954a0a9238ee73c7a04cc9a33 Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Tue, 4 Feb 2025 14:08:38 +0800 Subject: [PATCH] :bug: Fix wrong IsAllSuccess value --- pkg/internal/grpc/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/internal/grpc/stream.go b/pkg/internal/grpc/stream.go index 717a33f..fefa137 100644 --- a/pkg/internal/grpc/stream.go +++ b/pkg/internal/grpc/stream.go @@ -53,7 +53,7 @@ func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamReques } return &proto.PushStreamResponse{ - IsAllSuccess: true, + IsAllSuccess: cnt == success, AffectedCount: int64(success), FailedCount: int64(cnt - success), }, nil @@ -100,7 +100,7 @@ func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamB } return &proto.PushStreamResponse{ - IsAllSuccess: true, + IsAllSuccess: cnt == success, AffectedCount: int64(success), FailedCount: int64(cnt - success), SuccessList: successes,