pub async fn connect<U: Upstream, S: StateStore>(
upstream: &U,
target: &U::Target,
request: WireRequest<()>,
limits: ResponsesWsLimits,
state: &GenerationStateAccess<'_, S>,
) -> Result<GenerationWsConnect, ResponsesWsConnectError>