Struct RFQStreamBuilder 

pub struct RFQStreamBuilder { /* private fields */ }

RFQStreamBuilder is a utility for constructing and managing a merged stream of RFQ (Request For Quote) providers in Tycho.

It allows you to:

• Register multiple RFQClient implementations, each providing its own stream of RFQ price updates.
• Dynamically decode incoming updates into Update objects using TychoStreamDecoder.

The build method consumes the builder and runs the event loop, sending decoded Updates through the provided mpsc::Sender. It returns an error if decoding an update or forwarding it to the channel fails.

Error Handling:

• Each RFQClient’s stream is expected to yield Result<(String, StateSyncMessage), RFQError>.
• If a client’s stream returns an Err (e.g., RFQError::FatalError), the client is removed from the merged stream, and the system continues running without it.

Implementations

impl RFQStreamBuilder

pub fn new() -> Self

pub fn add_client<T>(self, name: &str, provider: Box<dyn RFQClient>) -> Self

where T: ProtocolSim + TryFromWithBlock<ComponentWithState, TimestampHeader, Error = InvalidSnapshotError> + Send + 'static,

pub async fn build(self, tx: Sender<Update>) -> Result<(), SimulationError>

pub async fn set_tokens(self, tokens: HashMap<Bytes, Token>) -> Self

Sets the currently known tokens which to be considered during decoding.

Protocol components containing tokens which are not included in this initial list, or added when applying deltas, will not be decoded.

Trait Implementations

impl Default for RFQStreamBuilder

fn default() -> RFQStreamBuilder

Returns the “default value” for a type.