summaryrefslogtreecommitdiffstats
path: root/src/service/tcp.rs
diff options
context:
space:
mode:
authorToby Vincent <tobyv@tobyvin.dev>2024-10-01 13:15:24 -0500
committerToby Vincent <tobyv@tobyvin.dev>2024-10-01 13:15:24 -0500
commitfe16a923190243dfde5db6ceff2ef0bcf9158926 (patch)
tree9b8b616e1972ca3ef6e28d29c980899af3ddde49 /src/service/tcp.rs
parente1d9c956beb6921b0d549248bea3a6853fde5f46 (diff)
feat: simplify service status type
Diffstat (limited to 'src/service/tcp.rs')
-rw-r--r--src/service/tcp.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/service/tcp.rs b/src/service/tcp.rs
index 42791bc..7b79afd 100644
--- a/src/service/tcp.rs
+++ b/src/service/tcp.rs
@@ -32,7 +32,7 @@ impl ServiceSpawner for Tcp {
Ok(conn) => {
// TODO: figure out how to wait for connection to close
conn.ready(Interest::READABLE).await?;
- tx.send_if_modified(|s| s.update(Status::Pass));
+ tx.send_if_modified(|s| s.update(Status::Ok));
}
Err(err) => {
tx.send_if_modified(|s| s.update(err.into()));
@@ -50,18 +50,18 @@ mod tests {
#[tracing_test::traced_test]
#[ignore]
async fn test_tcp_watch() {
- let (tx, mut rx) = tokio::sync::watch::channel(Status::default());
+ let (tx, mut rx) = tokio::sync::watch::channel(Status::Error(None));
let tests = tokio::spawn(async move {
- assert!(matches!(*rx.borrow_and_update(), Status::Unknown));
+ assert!(matches!(*rx.borrow_and_update(), Status::Error(None)));
rx.changed().await.unwrap();
- assert!(matches!(*rx.borrow_and_update(), Status::Pass));
+ assert!(matches!(*rx.borrow_and_update(), Status::Ok));
rx.changed().await.unwrap();
assert_eq!(
*rx.borrow_and_update(),
- Status::Fail(Some(String::from("Disconnected")))
+ Status::Error(Some(String::from("Disconnected")))
);
});