arcon 0.2.1

A runtime for writing streaming applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use prost::Message;

#[cfg_attr(feature = "arcon_serde", derive(serde::Serialize, serde::Deserialize))]
#[derive(Message, Clone)]
pub struct ProstOption<A: Message + Default> {
    #[prost(message, tag = "1")]
    pub inner: Option<A>,
}

impl<A: Message + Default> From<Option<A>> for ProstOption<A> {
    fn from(inner: Option<A>) -> Self {
        ProstOption { inner }
    }
}

impl<A: Message + Default> From<ProstOption<A>> for Option<A> {
    fn from(opt: ProstOption<A>) -> Self {
        opt.inner
    }
}