anycall/rpc.py
def close(self):
        """
        Stop listing for new connections and close all open connections.
        
        :returns: Deferred that calls back once everything is closed.
        """
        assert self._opened, "RPC System is not opened"
        logger.debug("Closing rpc system. Stopping ping loop")
        self._ping_loop.stop()
        if self._ping_current_iteration:
            self._ping_current_iteration.cancel()
        return self._connectionpool.close()
def close(self):
        """
        Stop listing for new connections and close all open connections.
        
        :returns: Deferred that calls back once everything is closed.
        """
        assert self._opened, "RPC System is not opened"
        logger.debug("Closing rpc system. Stopping ping loop")
        self._ping_loop.stop()
        if self._ping_current_iteration:
            self._ping_current_iteration.cancel()
        return self._connectionpool.close()
def close ( self ) : assert self . _opened , "RPC System is not opened" logger . debug ( "Closing rpc system. Stopping ping loop" ) self . _ping_loop . stop ( ) if self . _ping_current_iteration : self . _ping_current_iteration . cancel ( ) return self . _connectionpool . close ( )
Stop listing for new connections and close all open connections.
        
        :returns: Deferred that calls back once everything is closed.
Stop listing for new connections and close all open connections . : returns : Deferred that calls back once everything is closed .