Compare commits

...

1 Commits

Author SHA1 Message Date
Jon Häggblad 4d09389c18 WIP 2022-12-14 19:54:45 +01:00
3 changed files with 12 additions and 8 deletions
@@ -384,7 +384,10 @@ where
match Pin::new(&mut self.real_receiver).poll_recv(cx) { match Pin::new(&mut self.real_receiver).poll_recv(cx) {
// in the case our real message channel stream was closed, we should also indicate we are closed // in the case our real message channel stream was closed, we should also indicate we are closed
// (and whoever is using the stream should panic) // (and whoever is using the stream should panic)
Poll::Ready(None) => Poll::Ready(None), Poll::Ready(None) => {
log::error!("real receiver ready(none)");
Poll::Ready(None)
}
Poll::Ready(Some((real_messages, conn_id))) => { Poll::Ready(Some((real_messages, conn_id))) => {
log::trace!("handling real_messages: size: {}", real_messages.len()); log::trace!("handling real_messages: size: {}", real_messages.len());
@@ -100,7 +100,7 @@ impl PartiallyDelegated {
let ret_err = loop { let ret_err = loop {
tokio::select! { tokio::select! {
_ = shutdown.recv() => { _ = shutdown.recv_with_delay() => {
log::trace!("GatewayClient listener: Received shutdown"); log::trace!("GatewayClient listener: Received shutdown");
log::debug!("GatewayClient listener: Exiting"); log::debug!("GatewayClient listener: Exiting");
return; return;
+7 -6
View File
@@ -254,12 +254,13 @@ impl TaskClient {
} }
pub async fn recv_with_delay(&mut self) { pub async fn recv_with_delay(&mut self) {
self.recv() pending().await
.then(|msg| async move { //self.recv()
sleep(Duration::from_secs(1)).await; // .then(|msg| async move {
msg // sleep(Duration::from_secs(1)).await;
}) // msg
.await // })
// .await
} }
pub async fn recv_timeout(&mut self) { pub async fn recv_timeout(&mut self) {