| 279 |
| 280 |
| 281 |
| 282 |
| 283 |
| 284 |
| 285 |
| 286 |
| 287 |
| 288 |
| 289 |
| 290 |
| 291 |
| 292 | |
def test_channel_endmarker_callback(self): |
l = [] |
channel = self.gw.remote_exec(source=''' |
channel.send(42) |
channel.send(13) |
channel.send(channel.gateway.newchannel()) |
''') |
channel.setcallback(l.append, 999) |
py.test.raises(IOError, channel.receive) |
-> channel.waitclose(TESTTIMEOUT) |
assert len(l) == 4 |
assert l[:2] == [42,13] |
assert isinstance(l[2], channel.__class__) |
assert l[3] == 999 | |