def METHOD_NAME(self, transmitter):
    """Configure a function that will be called for every set of records.
    The function looks like:
        def transmitter(timestamp, records) -> Boolean:
            ...
    """
    self.transmitter = transmitter