def test_whenConnectedLater(self):
"""
L{ClientService.whenConnected} returns a L{Deferred} that fires when a
connection is established.
"""
clock = Clock()
cq, service = self.makeReconnector(fireImmediately=False, clock=clock)
a = service.whenConnected()
b = service.whenConnected()
self.assertNoResult(a)
self.assertNoResult(b)
cq.connectQueue[0].callback(None)
resultA = self.successResultOf(a)
resultB = self.successResultOf(b)
self.assertIdentical(resultA, resultB)
self.assertIdentical(resultA, cq.applicationProtocols[0])
评论列表
文章目录