pub trait SubscriptionValidator {
type Parser: StreamParser;
// Required method
fn validate<'life0, 'async_trait, Exchange, Instrument, Kind>(
instrument_map: Map<Instrument::Id>,
websocket: &'life0 mut WebSocket,
) -> Pin<Box<dyn Future<Output = Result<Map<Instrument::Id>, SocketError>> + Send + 'async_trait>>
where Exchange: Connector + Send + 'async_trait,
Instrument: InstrumentData + 'async_trait,
Kind: SubscriptionKind + Send + 'async_trait,
'life0: 'async_trait;
}Expand description
Defines how to validate that actioned market data
Subscriptions were accepted by the exchange.
Required Associated Types§
type Parser: StreamParser
Required Methods§
fn validate<'life0, 'async_trait, Exchange, Instrument, Kind>(
instrument_map: Map<Instrument::Id>,
websocket: &'life0 mut WebSocket,
) -> Pin<Box<dyn Future<Output = Result<Map<Instrument::Id>, SocketError>> + Send + 'async_trait>>where
Exchange: Connector + Send + 'async_trait,
Instrument: InstrumentData + 'async_trait,
Kind: SubscriptionKind + Send + 'async_trait,
'life0: 'async_trait,
Object Safety§
This trait is not object safe.