def flush(self):
        self._flush_notification.set()
        if self.sender:
            self.sender.start()
Publish an iterable of messages to the given topic over tcp.
dataset/ETHPy150Open Microsoft/ApplicationInsights-Python/applicationinsights/channel/AsynchronousQueue.py/AsynchronousQueue.flush--crossover with--dataset/ETHPy150Open wtolson/gnsq/gnsq/nsqd.py/Nsqd.multipublish_tcp