discardEmptyOutboundBuffers() — netty Function Reference

Architecture documentation for the discardEmptyOutboundBuffers() function in CloseNotifyTest.java from the netty codebase.

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ discardEmptyOutboundBuffers() — netty Function Reference

Dependency Diagram

graph TD
  e3e1dd51_18ae_e079_751c_f22cc096ec24["discardEmptyOutboundBuffers()"]
  91635dfc_456c_fec9_4413_a1ee45d49032["CloseNotifyTest"]
  e3e1dd51_18ae_e079_751c_f22cc096ec24 -->|defined in| 91635dfc_456c_fec9_4413_a1ee45d49032
  c8dc5de5_36bd_d22b_8ec3_7c93cc9586c8["eventsOrder()"]
  c8dc5de5_36bd_d22b_8ec3_7c93cc9586c8 -->|calls| e3e1dd51_18ae_e079_751c_f22cc096ec24
  style e3e1dd51_18ae_e079_751c_f22cc096ec24 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/CloseNotifyTest.java lines 213–224

    private static void discardEmptyOutboundBuffers(EmbeddedChannel channel) {
        Queue<Object> outbound = channel.outboundMessages();
        while (outbound.peek() instanceof ByteBuf) {
            ByteBuf buf = (ByteBuf) outbound.peek();
            if (!buf.isReadable()) {
                buf.release();
                outbound.poll();
            } else {
                break;
            }
        }
    }