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);
        }

    }
Monitors Callback Coordinators.
Trigger timeouts if needed and remove coordinators from list that timed out.