in tchannel-core/src/main/java/com/uber/tchannel/handlers/LoadControlHandler.java [48:56]
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
if (msg instanceof Response) {
ChannelConfig config = ctx.channel().config();
if (--outstanding <= low && !config.isAutoRead()) {
config.setAutoRead(true);
}
}
ctx.write(msg, promise);
}