| 2396 | Event.SESSION_FINAL, Event.CONNECTION_FINAL) |
| 2397 | |
| 2398 | def testDeliveryEventsDisp(self): |
| 2399 | snd, rcv = self.testFlowEvents() |
| 2400 | snd.open() |
| 2401 | dlv = snd.delivery("delivery") |
| 2402 | snd.send(str2bin("Hello World!")) |
| 2403 | assert snd.advance() |
| 2404 | self.expect(Event.LINK_LOCAL_OPEN, Event.TRANSPORT) |
| 2405 | self.pump() |
| 2406 | self.expect(Event.LINK_FLOW) |
| 2407 | rdlv = rcv.current |
| 2408 | assert rdlv != None |
| 2409 | assert rdlv.tag == "delivery" |
| 2410 | rdlv.update(Delivery.ACCEPTED) |
| 2411 | self.pump() |
| 2412 | event = self.expect(Event.DELIVERY) |
| 2413 | assert event.context == dlv, (dlv, event.context) |
| 2414 | |
| 2415 | def testConnectionBOUND_UNBOUND(self): |
| 2416 | c = Connection() |