pulsar_binary_protocol_spec/client_handler/
pending_requests.rs

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>),
}