(self, mux, channel)
| 461 | |
| 462 | class MuxWrapper(SockWrapper): |
| 463 | def __init__(self, mux, channel): |
| 464 | SockWrapper.__init__(self, mux.rsock, mux.wsock) |
| 465 | self.mux = mux |
| 466 | self.channel = channel |
| 467 | self.mux.channels[channel] = self.got_packet |
| 468 | self.socks = [] |
| 469 | debug2('new channel: %d\n' % channel) |
| 470 | |
| 471 | def __del__(self): |
| 472 | self.nowrite() |