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
15

use crate::commands::{ProducerCommand, ProducerSuccessCommand};

use super::Respond;

pub struct SessionCreateProducerRespond {}
impl Respond for SessionCreateProducerRespond {
    type Request = ProducerCommand;
    type Response = ProducerSuccessCommand;
    type Error = SessionCreateProducerRespondError;
}

make_x_respond_error!(
    SessionCreateProducer;
    ServiceNotReady "TODO"
);