core/src/main/java/org/infinispan/util/concurrent/CommandAckCollector.java
/**
       * Invoked when the future is completed, it must cleanup all task related to this collector.
       * <p>
       * The tasks includes removing the collector from the map and cancel the timeout task.
       */
Invoked when the future is completed, it must cleanup all task related to this collector.

The tasks includes removing the collector from the map and cancel the timeout task.
Invoked when the future is completed it must cleanup all task related to this collector . The tasks includes removing the collector from the map and cancel the timeout task .
@Override
      public final void accept(T t, Throwable throwable) {
         if (trace) {
            log.tracef("[Collector#%s] Collector completed with ret=%s, throw=%s", id, t, throwable);
         }
         collectorMap.remove(id);
         timeoutTask.cancel(false);
      }
@ Override public final void accept ( T t , Throwable throwable ) { if ( trace ) { log . tracef ( "[Collector#%s] Collector completed with ret=%s, throw=%s" , id , t , throwable ) ; } collectorMap . remove ( id ) ; timeoutTask . cancel ( false ) ; }
Invoked when the future is completed, it must cleanup all task related to this collector.
Invoked when the future is completed it must cleanup all task related to this collector .