pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
1
2
3
4
5
6
7
8

use crate::client_responds::{ProducerSendRespond, Respond};

pub type HandlerReplyProducerSendChannelMessage =
    Result<<ProducerSendRespond as Respond>::Response, <ProducerSendRespond as Respond>::Error>;

pub enum HandlerReplyProducerChannelMessage {
    ReplySend(HandlerReplyProducerSendChannelMessage),
}