def __init__(self, *,
                 host,
                 port,
                 flush_iteration):
        """
        Args:
            flush_iteration: how many send() calls before we flush the buffer
        """
        U.assert_type(flush_iteration, int)
        self._client = ZmqSender(host=host,
                                 port=port)
        self._exp_buffer = ExpBuffer()
        self._flush_tracker = PeriodicTracker(flush_iteration)

        Args:
            flush_iteration: how many send() calls before we flush the buffer
        
surreal/distributed/exp_sender.py