cloud-sdk 0.49.0

no_std-first provider-neutral cloud SDK foundations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! Successful streaming completion metadata.

use super::{StreamProgress, StreamSinkMode};

/// Successful accounting completion.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct StreamCompletion {
    pub(super) progress: StreamProgress,
    pub(super) sink_mode: StreamSinkMode,
}

impl StreamCompletion {
    /// Returns final actual counters.
    #[must_use]
    pub const fn progress(self) -> StreamProgress {
        self.progress
    }

    /// Reports whether the sink must commit its hidden transactional state.
    #[must_use]
    pub const fn requires_sink_commit(self) -> bool {
        matches!(self.sink_mode, StreamSinkMode::Transactional)
    }
}