'Wake up the loop and force C{runUntilCurrent} to run immediately in the
next timed iteration.'

def doRead(self):

    result = _Waker.doRead(self)
    self.reactor._scheduleSimulate(True)
    return result
