pulsar_binary_protocol_spec/client_responds/
session_create_consumer_respond.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
use crate::commands::{SubscribeCommand, SuccessCommand};

use super::Respond;

pub struct SessionCreateConsumerRespond {}
impl Respond for SessionCreateConsumerRespond {
    type Request = SubscribeCommand;
    type Response = SuccessCommand;
    type Error = SessionCreateConsumerRespondError;
}

make_x_respond_error!(
    SessionCreateConsumer;
);