async def METHOD_NAME(
    self, continuation, client_call_details, request_iterator
):
    if self.tracing_skipped(client_call_details):
        return await continuation(client_call_details, request_iterator)
    with self._start_interceptor_span(
        client_call_details.method,
    ) as span:
        new_details = self.propagate_trace_in_details(client_call_details)
        resp = await continuation(new_details, request_iterator)
        return self._wrap_stream_response(span, resp)