use serde::{Deserialize, Serialize};
#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
pub struct EndOfStream {
#[serde(rename = "last_seq_no")]
pub last_seq_no: i32,
#[serde(rename = "message")]
pub message: Message,
}
impl EndOfStream {
pub fn new(last_seq_no: i32, message: Message) -> EndOfStream {
EndOfStream {
last_seq_no,
message,
}
}
}
#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
pub enum Message {
#[serde(rename = "EndOfStream")]
EndOfStream,
}
impl Default for Message {
fn default() -> Message {
Self::EndOfStream
}
}