openraft 0.10.0-alpha.18

Advanced Raft consensus
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
25
26
27
28
29
30

use crate::RaftTypeConfig;
use crate::engine::Respond;

/// A respond waiting for an IO condition to be satisfied.
///
/// Stores the expected progress value that must be reached before sending the respond.
#[derive(Debug)]
pub(crate) struct PendingRespond<C, V>
where C: RaftTypeConfig
{
    /// The expected progress value that must be reached before sending the respond.
    wait_for: V,
    respond: Respond<C>,
}

impl<C, V> PendingRespond<C, V>
where C: RaftTypeConfig
{
    pub(crate) fn new(wait_for: V, respond: Respond<C>) -> Self {
        Self { wait_for, respond }
    }

    pub(crate) fn wait_for(&self) -> &V {
        &self.wait_for
    }

    pub(crate) fn into_respond(self) -> Respond<C> {
        self.respond
    }
}