Struct Cache 

pub struct Cache { /* private fields */ }

Default MessageProcessor implementation that maintains market and order caches.

It updates an internal StreamState to apply incremental updates to market and order books.

Trait Implementations

impl Clone for Cache

fn clone(&self) -> Cache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Cache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MessageProcessor for Cache

type Output = CachedMessage

The processed message type produced by process_message

fn process_message(&mut self, message: ResponseMessage) -> Option<Self::Output>

Process an incoming ResponseMessage.

fn on_message_received(&mut self, raw: Bytes, message: &ResponseMessage)

Called with the raw JSON bytes and a reference to the parsed message before Self::process_message.