| 2469 | Event.TRANSPORT_HEAD_CLOSED, Event.TRANSPORT_CLOSED) |
| 2470 | |
| 2471 | def testLinkDetach(self): |
| 2472 | c1 = Connection() |
| 2473 | c1.collect(self.collector) |
| 2474 | t1 = Transport() |
| 2475 | t1.bind(c1) |
| 2476 | c1.open() |
| 2477 | s1 = c1.session() |
| 2478 | s1.open() |
| 2479 | l1 = s1.sender("asdf") |
| 2480 | l1.open() |
| 2481 | l1.detach() |
| 2482 | self.expect_until(Event.LINK_LOCAL_DETACH, Event.TRANSPORT) |
| 2483 | |
| 2484 | c2 = Connection() |
| 2485 | c2.collect(self.collector) |
| 2486 | t2 = Transport() |
| 2487 | t2.bind(c2) |
| 2488 | |
| 2489 | pump(t1, t2) |
| 2490 | |
| 2491 | self.expect_until(Event.LINK_REMOTE_DETACH) |
| 2492 | |
| 2493 | class PeerTest(CollectorTest): |
| 2494 | |