pysyncobj/transport.py
def _onNewIncomingConnection(self, conn):
        """
        Callback for connections initiated by the other side

        :param conn: connection object
        :type conn: TcpConnection
        """

        self._unknownConnections.add(conn)
        encryptor = self._syncObj.encryptor
        if encryptor:
            conn.encryptor = encryptor
        conn.setOnMessageReceivedCallback(functools.partial(self._onIncomingMessageReceived, conn))
        conn.setOnDisconnectedCallback(functools.partial(self._onDisconnected, conn))
def _onNewIncomingConnection(self, conn):
        self._unknownConnections.add(conn)
        encryptor = self._syncObj.encryptor
        if encryptor:
            conn.encryptor = encryptor
        conn.setOnMessageReceivedCallback(functools.partial(self._onIncomingMessageReceived, conn))
        conn.setOnDisconnectedCallback(functools.partial(self._onDisconnected, conn))
def _onNewIncomingConnection ( self , conn ) : self . _unknownConnections . add ( conn ) encryptor = self . _syncObj . encryptor if encryptor : conn . encryptor = encryptor conn . setOnMessageReceivedCallback ( functools . partial ( self . _onIncomingMessageReceived , conn ) ) conn . setOnDisconnectedCallback ( functools . partial ( self . _onDisconnected , conn ) )
Callback for connections initiated by the other side

        :param conn: connection object
        :type conn: TcpConnection
Callback for connections initiated by the other side