Channel.bytesBeforeUnwritable() is renamed to writableBytes() and isW…

…ritable() is removed (#2351)

- netty/netty#12530
- Temporary build on CI with PR in sock-proxy
netty-contrib/socks-proxy#10

.github/workflows/check_transport.yml

@@ -68,8 +68,10 @@ jobs:
           path: codec-extras
       - uses: actions/checkout@v3
         with:
-          repository: netty-contrib/socks-proxy
+          # TODO temporary https://github.com/netty-contrib/socks-proxy/pull/10
+          repository: violetagg/socks-proxy
           path: socks-proxy
+          ref: pending-write-queue
       - uses: gradle/wrapper-validation-action@v1
       - name: Set up JDK 17
         uses: actions/setup-java@v3

reactor-netty-core/src/main/java/reactor/netty/channel/MonoSendMany.java

@@ -295,7 +295,7 @@ public void run() {
 						//"FutureReturnValueIgnored" this is deliberate
 						ctx.write(encodedMessage).addListener(this);
 
-						if (parent.predicate.test(sourceMessage) || !ctx.channel().isWritable() || readableBytes > ctx.channel().bytesBeforeUnwritable()) {
+						if (parent.predicate.test(sourceMessage) || readableBytes > ctx.channel().writableBytes()) {
 							needFlush = false;
 							ctx.flush();
 						}