code: def register_incoming_conn(self, conn):
          
          assert conn, "conn is required"
          conn.set_outbound_pending_change_callback(self._on_conn_change)
          self.connections.appendleft(conn)
          self._set_on_close_cb(conn)
          self._on_conn_change()
docs: Add incoming connection into the heap.