| 2633 | Event.TRANSPORT_HEAD_CLOSED, Event.TRANSPORT_CLOSED) |
| 2634 | |
| 2635 | def testLinkDetach(self): |
| 2636 | c1 = Connection() |
| 2637 | c1.collect(self.collector) |
| 2638 | t1 = Transport() |
| 2639 | t1.bind(c1) |
| 2640 | c1.open() |
| 2641 | s1 = c1.session() |
| 2642 | s1.open() |
| 2643 | l1 = s1.sender("asdf") |
| 2644 | l1.open() |
| 2645 | l1.detach() |
| 2646 | self.expect_until(Event.LINK_LOCAL_DETACH, Event.TRANSPORT) |
| 2647 | |
| 2648 | c2 = Connection() |
| 2649 | c2.collect(self.collector) |
| 2650 | t2 = Transport() |
| 2651 | t2.bind(c2) |
| 2652 | |
| 2653 | pump(t1, t2) |
| 2654 | |
| 2655 | self.expect_until(Event.LINK_REMOTE_DETACH) |
| 2656 | |
| 2657 | |
| 2658 | class PeerTest(CollectorTest): |