1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
use std::collections::BTreeMap; use crate::{ client_channel::FC_Sender, client_channel_messages::{ handler_reply_consumer_channel_message::HandlerReplyConsumerAckChannelMessage, handler_reply_session_channel_message::{ HandlerReplySessionCreateConsumerChannelMessage, HandlerReplySessionCreateProducerChannelMessage, }, }, client_responds::{Respond, SessionCreateConsumerRespond, SessionCreateProducerRespond}, types::RequestId, }; pub type PendingRequests = BTreeMap<RequestId, PendingRequestValue>; pub enum PendingRequestValue { SessionCreateProducer( <SessionCreateProducerRespond as Respond>::Request, FC_Sender<HandlerReplySessionCreateProducerChannelMessage>, ), SessionCreateConsumer( <SessionCreateConsumerRespond as Respond>::Request, FC_Sender<HandlerReplySessionCreateConsumerChannelMessage>, ), ConsumerAck(FC_Sender<HandlerReplyConsumerAckChannelMessage>), }