Algostream_data_ingestion.ExchangeAbstract interface that each concrete exchange (Binance, Coinbase, …) implements.
The supervisor instantiates one of these per configured exchange and drives the WebSocket loop against it.
module type S = sig ... end