Type Alias BidiEvent
Source pub type BidiEvent = Event<ServerEnvelope, ServerEnvelope>;
pub enum BidiEvent {
Started {
keepalive_interval_ms: u32,
},
Applied {
id: u64,
targets: Vec<(Topic, u64)>,
},
GroupMessages {
messages: Vec<ServerEnvelope>,
},
WelcomeMessages {
messages: Vec<ServerEnvelope>,
},
}
The first response supplies the server keepalive interval.
An accepted update supplies fixed targets for newly added topics.
Group envelopes in wire order.
Welcome envelopes in wire order.