pulsar_binary_protocol_spec/client_handler/
pending_messages.rs

1
2
3
4
5
use std::collections::HashMap;

use crate::{commands::MessageCommand, types::ConsumerId};

pub type PendingMessages = HashMap<ConsumerId, Vec<MessageCommand>>;