def test_runTask_immediately_stops_replaced_task(self):
        @task
        def myTask(s):
            for n in range(2):
                self.trace.append('%s %s' % (s, n))
                yield WaitForNextPump()

        t = myTask('Alpha')
        u = myTask('Beta')

        self.collection.runTask('sdjsdj', t)
        self.serviceProvider.eventPump.pump()
        self.collection.runTask('sdjsdj', u)
        self.serviceProvider.eventPump.pump()
        self.serviceProvider.eventPump.pump()
        self.assertEqual('fred', self.trace)