def connection_made(self, transport):
    'asyncio callback when a connection is opened.'
    assert (not self._transport)
    logger.debug(('Connected & Listening: %s:%d' % (self.dstaddr, self.dstport)))
    self._transport = transport
    if self.on_connection_send_msg:
        self.send_message(self.on_connection_send_msg)
        self.on_connection_send_msg = None
    self.on_open()
asyncio callback when a connection is opened.
def connection_made(self, transport):
    
    assert (not self._transport)
    logger.debug(('Connected & Listening: %s:%d' % (self.dstaddr, self.dstport)))
    self._transport = transport
    if self.on_connection_send_msg:
        self.send_message(self.on_connection_send_msg)
        self.on_connection_send_msg = None
    self.on_open()