pub async fn replay_normalized(
base_url: &str,
options: Vec<ReplayNormalizedRequestOptions>,
signal: Arc<AtomicBool>,
) -> Result<impl Stream<Item = Result<WsMessage>>>
pub async fn replay_normalized(
base_url: &str,
options: Vec<ReplayNormalizedRequestOptions>,
signal: Arc<AtomicBool>,
) -> Result<impl Stream<Item = Result<WsMessage>>>