its spelled udp

getsentry · Feb 5, 2024 · 606524c · 606524c
1 parent e92858f
commit 606524c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/crates/symbolicator-stress/src/logging.rs b/crates/symbolicator-stress/src/logging.rs
@@ -22,7 +22,7 @@ pub struct Config {
 pub struct Guard {
     sentry: Option<sentry::ClientInitGuard>,
     pub http_sink: Option<Pin<Box<dyn Future<Output = ()> + Send>>>,
-    pub upd_sink: Option<Pin<Box<dyn Future<Output = ()> + Send>>>,
+    pub udp_sink: Option<Pin<Box<dyn Future<Output = ()> + Send>>>,
 }
 
 pub fn init(config: Config) -> Guard {
@@ -91,7 +91,7 @@ pub fn init(config: Config) -> Guard {
         listener.set_nonblocking(true).unwrap();
         let socket = listener.local_addr().unwrap();
 
-        guard.upd_sink = Some(Box::pin(async move {
+        guard.udp_sink = Some(Box::pin(async move {
             let listener = tokio::net::UdpSocket::from_std(listener).unwrap();
             let mut buf = Vec::with_capacity(1024);
             loop {

diff --git a/crates/symbolicator-stress/src/main.rs b/crates/symbolicator-stress/src/main.rs
@@ -66,7 +66,7 @@ fn main() -> Result<()> {
     if let Some(http_sink) = logging_guard.http_sink.take() {
         runtime.spawn(http_sink);
     }
-    if let Some(udp) = logging_guard.upd_sink.take() {
+    if let Some(udp) = logging_guard.udp_sink.take() {
         runtime.spawn(udp);
     }