- deliverer.schedule(2, future2.set, 'second')
- deliverer.schedule(1, future1.set, 'first')
- self.assertEqual('first', future1.get(self.TIMEOUT))
- self.assertRaises(pykka.Timeout, future2.get, .1)
- mock_now.return_value = 3
- self.assertEqual('second', future2.get(self.TIMEOUT))
+ deliverer.schedule(2, receiver, 'second')
+ deliverer.schedule(1, receiver, 'first')
+ deliverer.schedule(3, receiver, 'failure').get(self.TIMEOUT)
+ receiver.assert_called_with('first')
+ mock_now.return_value = 2.5
+ deliverer.schedule(3, receiver, 'failure').get(self.TIMEOUT)
+ self.stop_proxy(deliverer)
+ receiver.assert_called_with('second')