Class Http2CodecUtil.SimpleChannelPromiseAggregator

    • Field Detail

      • expectedCount

        private int expectedCount
      • doneCount

        private int doneCount
      • aggregateFailure

        private java.lang.Throwable aggregateFailure
      • doneAllocating

        private boolean doneAllocating
    • Method Detail

      • newPromise

        public ChannelPromise newPromise()
        Allocate a new promise which will be used to aggregate the overall success of this promise aggregator.
        Returns:
        A new promise which will be aggregated. null if doneAllocatingPromises() was previously called.
      • doneAllocatingPromises

        public ChannelPromise doneAllocatingPromises()
        Signify that no more newPromise() allocations will be made. The aggregation can not be successful until this method is called.
        Returns:
        The promise that is the aggregation of all promises allocated with newPromise().
      • tryFailure

        public boolean tryFailure​(java.lang.Throwable cause)
        Description copied from interface: Promise
        Marks this future as a failure and notifies all listeners.
        Specified by:
        tryFailure in interface Promise<java.lang.Void>
        Overrides:
        tryFailure in class DefaultPromise<java.lang.Void>
        Returns:
        true if and only if successfully marked this future as a failure. Otherwise false because this future is already marked as either a success or a failure.
      • trySuccess

        public boolean trySuccess​(java.lang.Void result)
        Description copied from interface: Promise
        Marks this future as a success and notifies all listeners.
        Specified by:
        trySuccess in interface Promise<java.lang.Void>
        Overrides:
        trySuccess in class DefaultPromise<java.lang.Void>
        Returns:
        true if and only if successfully marked this future as a success. Otherwise false because this future is already marked as either a success or a failure.
      • allowFailure

        private boolean allowFailure()
      • awaitingPromises

        private boolean awaitingPromises()
      • allPromisesDone

        private boolean allPromisesDone()
      • tryPromise

        private boolean tryPromise()
      • setAggregateFailure

        private void setAggregateFailure​(java.lang.Throwable cause)