HyperNet/Nexus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Fix wrong IsAllSuccess value

Browse Source
This commit is contained in:
LittleSheep 2025-02-04 14:08:38 +08:00
parent 0f350d00a8
commit 4675b65476
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/internal/grpc/stream.go
View File

@ -53,7 +53,7 @@ func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamReques
} }
return &proto.PushStreamResponse{ return &proto.PushStreamResponse{
IsAllSuccess: true, IsAllSuccess: cnt == success,
AffectedCount: int64(success), AffectedCount: int64(success),
FailedCount: int64(cnt - success), FailedCount: int64(cnt - success),
}, nil }, nil
@ -100,7 +100,7 @@ func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamB
} }
return &proto.PushStreamResponse{ return &proto.PushStreamResponse{
IsAllSuccess: true, IsAllSuccess: cnt == success,
AffectedCount: int64(success), AffectedCount: int64(success),
FailedCount: int64(cnt - success), FailedCount: int64(cnt - success),
SuccessList: successes, SuccessList: successes,