ts API
            ack()

        if not request.lazy_only:
            # start the listener function asynchronously
            def run_ack_function_asynchronously():
                nonlocal response
                try:
                    self.listener_start_handler.handle(
                        request=request,
                        response=response,
                    )
                    listener.run_ack_function(request=request, response=response)
                except Exception as e:
      