drain() — netty Function Reference

Architecture documentation for the drain() function in Recycler.java from the netty codebase.

Function java CommonUtil Logging

Entity Profile

CommonUtil→ Logging→ drain() — netty Function Reference

Dependency Diagram

graph TD
  61df7570_a6e3_8a6e_f34b_b337c0db1999["drain()"]
  97ffd903_aa9f_4bb1_fb52_3d8d31957095["BlockingMessageQueue"]
  61df7570_a6e3_8a6e_f34b_b337c0db1999 -->|defined in| 97ffd903_aa9f_4bb1_fb52_3d8d31957095
  style 61df7570_a6e3_8a6e_f34b_b337c0db1999 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/Recycler.java lines 694–702

        @Override
        public int drain(Consumer<T> c, int limit) {
            T obj;
            int i = 0;
            for (; i < limit && (obj = poll()) != null; i++) {
                c.accept(obj);
            }
            return i;
        }