promise.setFailure(new IllegalStateException("Channel closed"));
} else {
final ByteBuf byteBufMsg = (ByteBuf) msg;
- if (pending.isEmpty() == false) {
+ if (!pending.isEmpty()) {
queueRequest(ctx, byteBufMsg, promise);
return;
}
} catch (final WritePendingException e) {
- if (wasPending == false) {
+ if (!wasPending) {
queueRequest(ctx, byteBufMsg, promise);
}
}