code: def connection_made(self, transport):
          
          self.transport = transport
          addr = self.transport.get_extra_info('peername')
          if not addr:
              addr = self.transport.get_extra_info('sockname')
          self.address = addr
          sock = transport.get_extra_info('socket')
          if sock:
              try:
                  sock.setsockopt(SOL_SOCKET, SO_KEEPALIVE, 1)
              except (OSError, NameError):
                  pass
          self.changed()
          self.producer.logger.debug('new connection %s', self)
          # let everyone know we have a connection with endpoint
          self.event('connection_made').fire()
docs: Sets the :attr:`transport`, fire the ``connection_made`` event
          and adds a :attr:`timeout` for idle connections.