pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
use crate::commands::{SendCommand, SendReceiptCommand};

use super::Respond;

pub struct ProducerSendRespond {}
impl Respond for ProducerSendRespond {
    type Request = SendCommand;
    type Response = SendReceiptCommand;
    type Error = ProducerSendRespondError;
}

make_x_respond_error!(
    ProducerSend;
);