#![allow(dead_code)]
use wasmsh_protocol::WorkerEvent;
pub(crate) fn get_stdout(events: &[WorkerEvent]) -> String {
let mut out = Vec::new();
for event in events {
if let WorkerEvent::Stdout(data) = event {
out.extend_from_slice(data);
}
}
String::from_utf8(out).unwrap_or_default()
}
pub(crate) fn get_stderr(events: &[WorkerEvent]) -> String {
let mut out = Vec::new();
for event in events {
if let WorkerEvent::Stderr(data) = event {
out.extend_from_slice(data);
}
}
String::from_utf8(out).unwrap_or_default()
}
pub(crate) fn get_exit(events: &[WorkerEvent]) -> i32 {
events
.iter()
.find_map(|event| match event {
WorkerEvent::Exit(status) => Some(*status),
_ => None,
})
.unwrap_or(-1)
}