pub async fn classify_sse<U: Upstream>(
upstream: &U,
target: &U::Target,
request: GuardianPreparedRequest,
context: GuardianStreamContext,
flow: &mut IdentityFlow,
limits: GuardianLimits,
stream_limits: GuardianStreamLimits,
) -> Result<GuardianStreamInvocation, TransformError>