issue #406: ensure broker_test waits for broker exit.

issue260
David Wilson 6 years ago
parent 10af266678
commit 802efa6ea6

@ -32,6 +32,7 @@ class DeferSyncTest(testlib.TestCase):
self.assertEquals(th, broker._thread) self.assertEquals(th, broker._thread)
finally: finally:
broker.shutdown() broker.shutdown()
broker.join()
def test_exception(self): def test_exception(self):
broker = self.klass() broker = self.klass()
@ -40,6 +41,7 @@ class DeferSyncTest(testlib.TestCase):
broker.defer_sync, lambda: int('dave')) broker.defer_sync, lambda: int('dave'))
finally: finally:
broker.shutdown() broker.shutdown()
broker.join()
if __name__ == '__main__': if __name__ == '__main__':

Loading…
Cancel
Save