servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestExecutor.java
/**
     * Execute all scheduled ({@code schedule}/{@code timer} methods) tasks whose time has come.  Any exceptions thrown
     * by tasks will propagate, preventing execution of any further tasks.
     *
     * @return this.
     */
Execute all scheduled ( schedule/ timer methods) tasks whose time has come.  Any exceptions thrown
by tasks will propagate, preventing execution of any further tasks.

@return this.
Execute all scheduled ( schedule / timer methods ) tasks whose time has come . Any exceptions thrown by tasks will propagate preventing execution of any further tasks . @return this .
public TestExecutor executeScheduledTasks() {
        SortedMap<Long, Queue<RunnableWrapper>> headMap = scheduledTasksByNano.headMap(currentScheduledNanos(), true);
        for (Iterator<Entry<Long, Queue<RunnableWrapper>>> i = headMap.entrySet().iterator(); i.hasNext();) {
            final Entry<Long, Queue<RunnableWrapper>> entry = i.next();
            execute(entry.getValue(), scheduledTasksExecuted);
            i.remove();
        }
        return this;
    }
public TestExecutor executeScheduledTasks ( ) { SortedMap < Long , Queue < RunnableWrapper > > headMap = scheduledTasksByNano . headMap ( currentScheduledNanos ( ) , true ) ; for ( Iterator < Entry < Long , Queue < RunnableWrapper > > > i = headMap . entrySet ( ) . iterator ( ) ; i . hasNext ( ) ; ) { final Entry < Long , Queue < RunnableWrapper > > entry = i . next ( ) ; execute ( entry . getValue ( ) , scheduledTasksExecuted ) ; i . remove ( ) ; } return this ; }
Execute all scheduled ({@code schedule}/{@code timer} methods) tasks whose time has come.
Execute all scheduled ( { @code schedule } / { @code timer } methods ) tasks whose time has come .