From ea8416fb8eab99b5f635567e85630fd0386e0414 Mon Sep 17 00:00:00 2001 From: Atmaram Naik Date: Fri, 9 Aug 2024 22:15:34 +0530 Subject: [PATCH] fix latest nightly issues --- corr-lib/src/journey/step/websocket/server/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/corr-lib/src/journey/step/websocket/server/mod.rs b/corr-lib/src/journey/step/websocket/server/mod.rs index 8f19076..6e510be 100644 --- a/corr-lib/src/journey/step/websocket/server/mod.rs +++ b/corr-lib/src/journey/step/websocket/server/mod.rs @@ -100,7 +100,7 @@ impl Executable for WebSocketServerStep { let new_ct_out = context.clone(); let om_out=self.hook.clone(); - let connect = async move||{ + let connect = async move|listner:TcpListener,om_out:WebSocketServerHook,new_ct_out:Context|{ while let Ok((stream,_)) = listner.accept().await{ let om=om_out.clone(); let new_ct = new_ct_out.clone(); @@ -109,7 +109,7 @@ impl Executable for WebSocketServerStep { }; Ok(true) }; - let handle = tokio::spawn(connect()); + let handle = tokio::spawn(connect(listner,om_out,new_ct_out)); Ok(vec![handle]) }