(self, mux, channel)
| 505 | class MuxWrapper(SockWrapper): |
| 506 | |
| 507 | def __init__(self, mux, channel): |
| 508 | SockWrapper.__init__(self, mux.rfile, mux.wfile) |
| 509 | self.mux = mux |
| 510 | self.channel = channel |
| 511 | self.mux.channels[channel] = self.got_packet |
| 512 | self.socks = [] |
| 513 | debug2('new channel: %d' % channel) |
| 514 | |
| 515 | def __del__(self): |
| 516 | self.nowrite() |