def METHOD_NAME(context, parsed, **kwargs):
    # type: (Dict[str, Any], Dict[str, Any], **Any) -> None
    span = context.pop("_sentrysdk_span", None)  # type: Optional[Span]
    # Span could be absent if the integration is disabled.
    if span is None:
        return
    span.__exit__(None, None, None)
    body = parsed.get("Body")
    if not isinstance(body, StreamingBody):
        return
    streaming_span = span.start_child(
        op=OP.HTTP_CLIENT_STREAM,
        description=span.description,
    )
    orig_read = body.read
    orig_close = body.close
    def sentry_streaming_body_read(*args, **kwargs):
        # type: (*Any, **Any) -> bytes
        try:
            ret = orig_read(*args, **kwargs)
            if not ret:
                streaming_span.finish()
            return ret
        except Exception:
            streaming_span.finish()
            raise
    body.read = sentry_streaming_body_read
    def sentry_streaming_body_close(*args, **kwargs):
        # type: (*Any, **Any) -> None
        streaming_span.finish()
        orig_close(*args, **kwargs)
    body.close = sentry_streaming_body_close