Struct MessageProcessor 

pub struct MessageProcessor {
    pub channel_id: ChannelId,
    pub input_receiver: Option<UnboundedReceiver<TickerMessage>>,
    pub output_sender: Sender<TickerMessage>,
    pub stats: Arc<RwLock<ProcessorStats>>,
    pub task_handle: Option<JoinHandle<()>>,
}

High-performance message processor with dedicated parsing task

Fields

channel_id: ChannelId

input_receiver: Option<UnboundedReceiver<TickerMessage>>

output_sender: Sender<TickerMessage>

stats: Arc<RwLock<ProcessorStats>>

task_handle: Option<JoinHandle<()>>

Implementations

impl MessageProcessor

pub fn new( channel_id: ChannelId, input_receiver: UnboundedReceiver<TickerMessage>, buffer_size: usize, ) -> (Self, Receiver<TickerMessage>)

Create a new message processor

pub fn start(&mut self)

Start the dedicated processing task

pub async fn get_stats(&self) -> ProcessorStats

Get current processor statistics

pub fn queue_size(&self) -> usize

Get current queue size (non-blocking)

pub async fn stop(&mut self)

Stop the processor

Trait Implementations

impl Debug for MessageProcessor

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

Formats the value using the given formatter.