Skip to content

Commit 1f97a54

Browse files
committed
fix: Fix missing logic to not output pending payloads on streaming connections
1 parent 2a5fd89 commit 1f97a54

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lc-lib/receiver/status.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,9 @@ func (p *poolConnectionStatus) Update() error {
7373
p.SetEntry("description", api.String(p.desc))
7474
p.SetEntry("completedLines", api.Number(p.lines))
7575
p.SetEntry("receivedBytes", api.Bytes(p.bytes))
76-
p.SetEntry("pendingPayloads", api.Number(len(p.progress)))
76+
if p.supportsAck {
77+
p.SetEntry("pendingPayloads", api.Number(len(p.progress)))
78+
}
7779
return nil
7880
}
7981

0 commit comments

Comments
 (0)