zlink_core/
reply.rs

1//! Method reply API.
2
3use serde::{Deserialize, Serialize};
4
5/// A successful method call reply.
6#[derive(Debug, Clone, Serialize, Deserialize)]
7pub struct Reply<Params> {
8    #[serde(skip_serializing_if = "Option::is_none")]
9    pub(super) parameters: Option<Params>,
10    #[serde(skip_serializing_if = "Option::is_none")]
11    pub(super) continues: Option<bool>,
12}
13
14impl<Params> Reply<Params> {
15    /// Create a new reply.
16    pub fn new(parameters: Option<Params>) -> Self {
17        Self {
18            parameters,
19            continues: None,
20        }
21    }
22
23    /// Set the continues flag.
24    pub fn set_continues(mut self, continues: Option<bool>) -> Self {
25        self.continues = continues;
26        self
27    }
28
29    /// The parameters of the reply.
30    pub fn parameters(&self) -> Option<&Params> {
31        self.parameters.as_ref()
32    }
33
34    /// Convert the reply into its parameters.
35    pub fn into_parameters(self) -> Option<Params> {
36        self.parameters
37    }
38
39    /// If there are more replies to come.
40    pub fn continues(&self) -> Option<bool> {
41        self.continues
42    }
43
44    /// Map the parameters of this reply using the provided function.
45    pub fn map<U, F>(self, f: F) -> Reply<U>
46    where
47        F: FnOnce(Params) -> U,
48    {
49        Reply {
50            parameters: self.parameters.map(f),
51            continues: self.continues,
52        }
53    }
54}
55
56impl<Params> From<Params> for Reply<Params> {
57    fn from(parameters: Params) -> Self {
58        Self::new(Some(parameters))
59    }
60}
61
62/// A reply result.
63pub type Result<Params, Error> = core::result::Result<Reply<Params>, Error>;
zlink_core/reply.rs

zlink_core/
reply.rs
