qbit/core/src/main/java/io/advantageous/qbit/reactive/Reactor.java
private void monitorCallbackCoordinators() {


        if (coordinatorList.size() > 0) {
            final List<CallbackCoordinator> removeList = new ArrayList<>(coordinatorList.size());

            for (CallbackCoordinator callable : coordinatorList) {
                if (callable.checkComplete()) {
                    callable.finished();
                    removeList.add(callable);
                } else if (callable.timedOut(currentTime)) {
                    removeList.add(callable);
                }
            }
            coordinatorList.removeAll(removeList);
        }

    }
private void monitorCallbackCoordinators() {


        if (coordinatorList.size() > 0) {
            final List<CallbackCoordinator> removeList = new ArrayList<>(coordinatorList.size());

            for (CallbackCoordinator callable : coordinatorList) {
                if (callable.checkComplete()) {
                    callable.finished();
                    removeList.add(callable);
                } else if (callable.timedOut(currentTime)) {
                    removeList.add(callable);
                }
            }
            coordinatorList.removeAll(removeList);
        }

    }
private void monitorCallbackCoordinators ( ) { if ( coordinatorList . size ( ) > 0 ) { final List < CallbackCoordinator > removeList = new ArrayList <> ( coordinatorList . size ( ) ) ; for ( CallbackCoordinator callable : coordinatorList ) { if ( callable . checkComplete ( ) ) { callable . finished ( ) ; removeList . add ( callable ) ; } else if ( callable . timedOut ( currentTime ) ) { removeList . add ( callable ) ; } } coordinatorList . removeAll ( removeList ) ; } }
Monitors Callback Coordinators.
Trigger timeouts if needed and remove coordinators from list that timed out.
Monitors Callback Coordinators . Trigger timeouts if needed and remove coordinators from list that timed out .