def test_channel_passing_over_channel(self): |
channel = self.gw.remote_exec(''' |
c = channel.gateway.newchannel() |
channel.send(c) |
c.send(42) |
''') |
c = channel.receive() |
x = c.receive() |
assert x == 42 |
|
|
-> channel.waitclose(TESTTIMEOUT) |
|
newchan = self.gw.remote_exec(''' |
assert %d not in channel.gateway._channelfactory._channels |
''' % (channel.id)) |
newchan.waitclose(TESTTIMEOUT) |
assert channel.id not in self.gw._channelfactory._channels |