Class HttpDestination.RequestTimeouts

  • All Implemented Interfaces:
    Destroyable
    Enclosing class:
    HttpDestination

    private class HttpDestination.RequestTimeouts
    extends CyclicTimeouts<HttpExchange>

    Enforces the total timeout for for exchanges that are still in the queue.

    The total timeout for exchanges that are not in the destination queue is enforced in HttpConnection.

    • Constructor Detail

      • RequestTimeouts

        private RequestTimeouts​(Scheduler scheduler)
    • Method Detail

      • onExpired

        protected boolean onExpired​(HttpExchange exchange)
        Description copied from class: CyclicTimeouts

        Invoked during the iteration when the given entity is expired.

        This method may be invoked multiple times, and even concurrently, for the same expirable entity and therefore the expiration of the entity, if any, should be an idempotent action.

        Specified by:
        onExpired in class CyclicTimeouts<HttpExchange>
        Parameters:
        exchange - the entity that is expired
        Returns:
        whether the entity should be removed from the iterator via Iterator.remove()