Small comment
This commit is contained in:
parent
18e745e2a1
commit
7cbd2a272e
@ -108,6 +108,8 @@ public class CompatibleObjectEncoder implements ChannelDownstreamHandler {
|
||||
writtenObjects ++;
|
||||
if (writtenObjects % resetInterval == 0) {
|
||||
oout.reset();
|
||||
|
||||
// Also discard the byproduct to avoid OOM on the sending side.
|
||||
buffer.discardReadBytes();
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user