pub trait RFQClient: Send + Sync {
// Required methods
fn stream(
&self,
) -> BoxStream<'static, Result<(String, StateSyncMessage<TimestampHeader>), RFQError>>;
fn request_binding_quote<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 GetAmountOutParams,
) -> Pin<Box<dyn Future<Output = Result<SignedQuote, RFQError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
}Required Methods§
Sourcefn stream(
&self,
) -> BoxStream<'static, Result<(String, StateSyncMessage<TimestampHeader>), RFQError>>
fn stream( &self, ) -> BoxStream<'static, Result<(String, StateSyncMessage<TimestampHeader>), RFQError>>
Returns a stream of updates tagged with the provider name.