def METHOD_NAME(*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