def __init__(self, channel, *args, **kwds):
        """
        \param channel is a Channel endpoint (fileno/recv/close
        methods expected)
        """
        threading.Thread.__init__(self, *args, **kwds)
        self._channel = channel
        self.__terms  = os.pipe()

        self._recv = channel.recv
        self._send = channel.send

        \param channel is a Channel endpoint (fileno/recv/close
        methods expected)
        
recipes/Python/576520_Multithreaded_MultiplexerDemultiplexer_allow/recipe-576520.py