pulsar_binary_protocol_spec/client_responds/
session_create_producer_respond.rs

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"
);