Skip to content

Commit

Permalink
Update encode.go
Browse files Browse the repository at this point in the history
  • Loading branch information
re-Tick committed Apr 12, 2024
1 parent 6e5a882 commit 3fd8c38
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions pkg/core/proxy/integrations/mongo/encode.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,8 +89,7 @@ func (m *Mongo) encodeMongo(ctx context.Context, logger *zap.Logger, reqBuf []by
// check for the request packet streaming for the mongo wire message
if val, ok := mongoRequest.(*models.MongoOpMessage); ok && hasSecondSetBit(val.FlagBits) {
for {
<
// read the streaming request packets
// read the streaming request packets
requestBuffer1, err := pUtil.ReadBytes(ctx, logger, clientConn)
if err != nil {
if err == io.EOF {
Expand Down

0 comments on commit 3fd8c38

Please sign in to comment.