use serde::{Deserialize, Serialize};
use serde_json::Value;
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct OutputMessage {
pub work_name: String,
pub result: Value,
}
impl OutputMessage {
pub fn new(work_name: impl Into<String>, result: Value) -> Self {
Self {
work_name: work_name.into(),
result,
}
}
pub fn to_ndjson(&self) -> Result<String, serde_json::Error> {
serde_json::to_string(self)
}
}