+
+// try {
+ final var req = new PendingWriteRequest(ctx, msg, promise);
+ // Preconditions.checkState(pending.size() < MAX_PENDING_WRITES,
+ // "Too much pending writes(%s) on channel: %s, remote window is not getting read or is too small",
+ // pending.size(), ctx.channel());
+ checkState(pending.offer(req), "Cannot pend another request write (pending count: %s) on channel: %s",
+ pending.size(), ctx.channel());