def schedule_absolute(self, duetime, action, state=None):

        def run(scheduler, state1):
            self.queue.remove(si)
            return action(scheduler, state1)

        si = ScheduledItem(self, state, run, duetime, self.comparer)
        self.queue.enqueue(si)
        return si.disposable
return assembly stats from all of the assemblers that
dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/virtualtimescheduler.py/VirtualTimeScheduler.schedule_absolute--crossover with--dataset/ETHPy150Open CGATOxford/cgat/obsolete/pipeline_metagenomebenchmark.py/buildAssemblyStats