Function stream_normalized 

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

Connects to the Tardis Machine WS streaming endpoint and returns a stream of WebSocket messages.

Errors

Returns an error if no options are provided, the exchange is BitMEX, or the connection fails.