frpc_lib/stream/
fluid_message_received.rs

1use chrono::{DateTime, Local};
2use prost_reflect::DynamicMessage;
3
4#[derive(Debug)]
5pub struct FluidMessageReceived {
6    pub date_time: DateTime<Local>,
7    pub message: DynamicMessage,
8}
9
10impl FluidMessageReceived {
11    pub fn new(message: DynamicMessage) -> FluidMessageReceived {
12        FluidMessageReceived {
13            date_time: Local::now(),
14            message,
15        }
16    }
17}