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 | |