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
use crate::commands::FlowCommand;

use super::HalfRequest;

pub struct ConsumerFlowHalfRequest {}
impl HalfRequest for ConsumerFlowHalfRequest {
    type Request = FlowCommand;
    type Error = ConsumerFlowHalfRequestError;
}

make_x_half_request_error!(
    ConsumerFlow;
);