def _async_socket(self):
        """
        Creates a new async socket if one doesn't already exist for this Client
        """
        if not self._async_socket_cache:
            self._async_socket_cache = self._connect_to_socket(zmq.asyncio.Context(), self.endpoint)

        return self._async_socket_cache
def _async_socket ( self ) : if not self . _async_socket_cache : self . _async_socket_cache = self . _connect_to_socket ( zmq . asyncio . Context ( ) , self . endpoint ) return self . _async_socket_cache
Creates a new async socket if one doesn't already exist for this Client