def flush(self):
        """Flush message queue if there's an active connection running"""
        self._pending_flush = False

        if self.handler is None or not self.handler.active or not self.send_queue:
            return

        self.handler.send_pack('a[%s]' % self.send_queue)
        self.send_queue = ''
dataset/ETHPy150Open benoitc/gaffer/gaffer/sockjs/session.py/Session.flush/original