Object() — netty Function Reference

Architecture documentation for the Object() function in DefaultPromise.java from the netty codebase.

Function java CommonUtil Concurrent

Entity Profile

CommonUtil→ Concurrent→ Object() — netty Function Reference

Dependency Diagram

graph TD
  528d1db1_c689_775e_0296_841bfcbd851f["Object()"]
  a0080a71_f091_42e0_8a20_424f0bf9d34a["DefaultPromise"]
  528d1db1_c689_775e_0296_841bfcbd851f -->|defined in| a0080a71_f091_42e0_8a20_424f0bf9d34a
  style 528d1db1_c689_775e_0296_841bfcbd851f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/DefaultPromise.java lines 798–838

    private synchronized Object progressiveListeners() {
        final GenericFutureListener listener = this.listener;
        final DefaultFutureListeners listeners = this.listeners;
        if (listener == null && listeners == null) {
            // No listeners added
            return null;
        }

        if (listeners != null) {
            // Copy DefaultFutureListeners into an array of listeners.
            DefaultFutureListeners dfl = listeners;
            int progressiveSize = dfl.progressiveSize();
            switch (progressiveSize) {
                case 0:
                    return null;
                case 1:
                    for (GenericFutureListener<?> l: dfl.listeners()) {
                        if (l instanceof GenericProgressiveFutureListener) {
                            return l;
                        }
                    }
                    return null;
            }

            GenericFutureListener<?>[] array = dfl.listeners();
            GenericProgressiveFutureListener<?>[] copy = new GenericProgressiveFutureListener[progressiveSize];
            for (int i = 0, j = 0; j < progressiveSize; i ++) {
                GenericFutureListener<?> l = array[i];
                if (l instanceof GenericProgressiveFutureListener) {
                    copy[j ++] = (GenericProgressiveFutureListener<?>) l;
                }
            }

            return copy;
        } else if (listener instanceof GenericProgressiveFutureListener) {
            return listener;
        } else {
            // Only one listener was added and it's not a progressive listener.
            return null;
        }
    }