@Test(timeout = TIMEOUT)
public void the_callback_is_fired_immediately_if_there_were_no_commands() throws InterruptedException {

    WorkerCounter counter = new WorkerCounter(realExecutor);
    counter.afterPreviousWorkersFinished(log("callback"));
    events.await(1, TIMEOUT);
    events.assertContains("callback");
}