Type Definition pulsar_binary_protocol_spec::client_handler::pending_messages::PendingMessages[][src]

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