pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
1
2
3
4
5

use std::collections::HashMap;

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

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