qbit/core/src/main/java/io/advantageous/qbit/reactive/Reactor.java
public void process() {

        /** Manages lists of coordinators, and callbacks which can come back async. */
        drainQueues();

        currentTime = timer.now();

        /* Check to see if callbacks completed or timed out. */
        monitorCallBacks();

        /* Check to see if coordinators completed or timed out. */
        monitorCallbackCoordinators();

        /* flush services. */
        collaboratingServices.forEach(ServiceProxyUtils::flushServiceProxy);

        processRepeatingTasks();
        processFireOnceTasks();
    }
public void process() {

        /** Manages lists of coordinators, and callbacks which can come back async. */
        drainQueues();

        currentTime = timer.now();

        /* Check to see if callbacks completed or timed out. */
        monitorCallBacks();

        /* Check to see if coordinators completed or timed out. */
        monitorCallbackCoordinators();

        /* flush services. */
        collaboratingServices.forEach(ServiceProxyUtils::flushServiceProxy);

        processRepeatingTasks();
        processFireOnceTasks();
    }
public void process ( ) { /** Manages lists of coordinators, and callbacks which can come back async. */ drainQueues ( ) ; currentTime = timer . now ( ) ; /* Check to see if callbacks completed or timed out. */ monitorCallBacks ( ) ; /* Check to see if coordinators completed or timed out. */ monitorCallbackCoordinators ( ) ; /* flush services. */ collaboratingServices . forEach ( ServiceProxyUtils :: flushServiceProxy ) ; processRepeatingTasks ( ) ; processFireOnceTasks ( ) ; }
Process items in reactor.
Process items in reactor .