75 lines
1.7 KiB
Rust
Raw Normal View History

2021-09-07 23:30:43 +08:00
use bytes::Bytes;
2021-07-21 15:43:05 +08:00
pub mod dart;
pub mod entities;
mod protobuf;
2021-10-14 14:34:22 +08:00
use crate::{dart::DartStreamSender, entities::SubscribeObject};
use lib_dispatch::prelude::ToBytes;
2021-09-07 23:30:43 +08:00
2021-10-05 11:46:56 +08:00
pub struct DartNotifyBuilder {
2021-09-07 23:30:43 +08:00
id: String,
payload: Option<Bytes>,
error: Option<Bytes>,
source: String,
2021-09-07 23:30:43 +08:00
ty: i32,
}
2021-10-05 11:46:56 +08:00
impl DartNotifyBuilder {
pub fn new<T: Into<i32>>(id: &str, ty: T, source: &str) -> Self {
2021-09-07 23:30:43 +08:00
Self {
id: id.to_owned(),
ty: ty.into(),
payload: None,
error: None,
source: source.to_owned(),
2021-09-07 23:30:43 +08:00
}
}
pub fn payload<T>(mut self, payload: T) -> Self
where
T: ToBytes,
{
match payload.into_bytes() {
Ok(bytes) => self.payload = Some(bytes),
Err(e) => {
log::error!("Set observable payload failed: {:?}", e);
2022-01-23 12:14:00 +08:00
}
2021-09-07 23:30:43 +08:00
}
self
}
pub fn error<T>(mut self, error: T) -> Self
where
T: ToBytes,
{
match error.into_bytes() {
Ok(bytes) => self.error = Some(bytes),
Err(e) => {
log::error!("Set observable error failed: {:?}", e);
2022-01-23 12:14:00 +08:00
}
2021-09-07 23:30:43 +08:00
}
self
}
2021-09-11 14:26:30 +08:00
pub fn send(self) {
2021-11-27 19:19:41 +08:00
let payload = self.payload.map(|bytes| bytes.to_vec());
2021-09-07 23:30:43 +08:00
2021-11-27 19:19:41 +08:00
let error = self.error.map(|bytes| bytes.to_vec());
2021-09-07 23:30:43 +08:00
2021-10-14 14:34:22 +08:00
let subject = SubscribeObject {
source: self.source,
2021-09-07 23:30:43 +08:00
ty: self.ty,
id: self.id,
payload,
error,
};
2021-09-08 18:25:32 +08:00
2021-10-05 11:46:56 +08:00
match DartStreamSender::post(subject) {
2022-01-23 12:14:00 +08:00
Ok(_) => {}
2021-09-07 23:30:43 +08:00
Err(error) => log::error!("Send observable subject failed: {}", error),
}
2021-07-21 15:43:05 +08:00
}
}