pub enum ClientDelivery {
Live {
message: Box<EventSubscriptionMessage>,
generation: u64,
},
ReplayStart {
session_id: SessionId,
generation: u64,
final_seq: u64,
rebuild: bool,
},
ReplayEvent {
session_id: SessionId,
generation: u64,
final_seq: u64,
event: Box<StoredEvent>,
},
ReplayEnd {
session_id: SessionId,
generation: u64,
final_seq: u64,
},
OutputSnapshot(OutputSnapshotEnvelope),
OutputDelta(OutputDelta),
OutputGap(OutputGap),
PluginEvent(ExtensionBusEventParams),
RecoveryFailed {
session_id: Option<SessionId>,
error: String,
},
Disconnected {
error: String,
},
RuntimeChanged(Box<RuntimeChangedNotification>),
}Expand description
The sole ordered delivery stream consumed by the UI.
The connection task is its only producer. Replays are injected into this stream before the live notifications buffered while their RPC is in flight.
Variants§
Live
ReplayStart
ReplayEvent
ReplayEnd
OutputSnapshot(OutputSnapshotEnvelope)
OutputDelta(OutputDelta)
OutputGap(OutputGap)
PluginEvent(ExtensionBusEventParams)
RecoveryFailed
Disconnected
RuntimeChanged(Box<RuntimeChangedNotification>)
Trait Implementations§
Source§impl Clone for ClientDelivery
impl Clone for ClientDelivery
Source§fn clone(&self) -> ClientDelivery
fn clone(&self) -> ClientDelivery
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for ClientDelivery
impl RefUnwindSafe for ClientDelivery
impl Send for ClientDelivery
impl Sync for ClientDelivery
impl Unpin for ClientDelivery
impl UnsafeUnpin for ClientDelivery
impl UnwindSafe for ClientDelivery
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more