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

        if self.is_disposed:
            raise DisposedException()

        dt = self.to_datetime(duetime)
        si = ScheduledItem(self, state, action, dt)

        with self.condition:
            if dt < self.now():
                self.ready_list.append(si)
            else:
                self.queue.enqueue(si)
            self.condition.notify()  # signal that a new item is available
            self.ensure_thread()

        return Disposable(si.cancel)
Schedules an action to be executed at duetime.
dataset/ETHPy150Open ReactiveX/RxPY/rx/concurrency/eventloopscheduler.py/EventLoopScheduler.schedule_absolute