servicetalk-concurrent-api/src/testFixtures/java/io/servicetalk/concurrent/api/TestExecutor.java
/**
     * Execute the next scheduled ({@code schedule}/{@code timer} methods) task whose time has come.  Any exceptions
     * thrown by the task will propagate.
     *
     * @return this.
     */
Execute the next scheduled ( schedule/ timer methods) task whose time has come.  Any exceptions
thrown by the task will propagate.

@return this.
Execute the next scheduled ( schedule / timer methods ) task whose time has come . Any exceptions thrown by the task will propagate . @return this .
public TestExecutor executeNextScheduledTask() {
        ConcurrentNavigableMap<Long, Queue<RunnableWrapper>> headMap =
                scheduledTasksByNano.headMap(currentScheduledNanos(), true);
        Entry<Long, Queue<RunnableWrapper>> entry = headMap.firstEntry();
        if (entry != null && executeOne(entry.getValue(), scheduledTasksExecuted)) {
            if (entry.getValue().isEmpty()) {
                removedScheduledQueue(entry.getKey());
            }
            return this;
        }
        throw new IllegalStateException("No scheduled tasks to execute");
    }
public TestExecutor executeNextScheduledTask ( ) { ConcurrentNavigableMap < Long , Queue < RunnableWrapper > > headMap = scheduledTasksByNano . headMap ( currentScheduledNanos ( ) , true ) ; Entry < Long , Queue < RunnableWrapper > > entry = headMap . firstEntry ( ) ; if ( entry != null && executeOne ( entry . getValue ( ) , scheduledTasksExecuted ) ) { if ( entry . getValue ( ) . isEmpty ( ) ) { removedScheduledQueue ( entry . getKey ( ) ) ; } return this ; } throw new IllegalStateException ( "No scheduled tasks to execute" ) ; }
Execute the next scheduled ({@code schedule}/{@code timer} methods) task whose time has come.
Execute the next scheduled ( { @code schedule } / { @code timer } methods ) task whose time has come .