1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crate::{
    client_half_requests::{
        ConsumerFlowHalfRequest, ConsumerRedeliverUnacknowledgedMessagesHalfRequest, HalfRequest,
    },
    client_responds::{ConsumerAckRespond, Respond},
    commands::MessageCommand,
};

pub type HandlerReplyConsumerFlowChannelMessage =
    Result<(), <ConsumerFlowHalfRequest as HalfRequest>::Error>;
pub type HandlerReplyConsumerGetMessageChannelMessage = Option<MessageCommand>;
pub type HandlerReplyConsumerAckChannelMessage =
    Result<<ConsumerAckRespond as Respond>::Response, <ConsumerAckRespond as Respond>::Error>;
pub type HandlerReplyConsumerRedeliverUnacknowledgedMessagesChannelMessage =
    Result<(), <ConsumerRedeliverUnacknowledgedMessagesHalfRequest as HalfRequest>::Error>;

pub enum HandlerReplyConsumerChannelMessage {
    ReplyFlow(HandlerReplyConsumerFlowChannelMessage),
    ReplyGetMessage(Box<HandlerReplyConsumerGetMessageChannelMessage>),
    ReplyAck(HandlerReplyConsumerAckChannelMessage),
    ReplyRedeliverUnacknowledgedMessages(
        HandlerReplyConsumerRedeliverUnacknowledgedMessagesChannelMessage,
    ),
}