def send(self, message):

        condition = threading.Condition()
        condition.acquire()
        self._queue.put((message, condition))
        condition.wait()
Send a message, blocking.
dataset/ETHPy150Open google/pywebsocket/mod_pywebsocket/msgutil.py/MessageSender.send