def METHOD_NAME():
    # We keep the connection open during `callback`. Closing the connection is the signal to the
    # caller that processing completed
    with redirect_stdout_stderr_exceptions_to_log():
        with connection:
            self.__callback(read_all_bytes(connection))