Add explicit drop on sender, log when finished consuming

This commit is contained in:
asonix 2023-07-16 15:07:26 -05:00
parent f3096ac76a
commit d3b16438c9

View file

@ -169,6 +169,9 @@ where
let _ = tx.send(res.map_err(Error::from)).await;
}
drop(tx);
tracing::debug!("Finished consuming field");
};
let stream = ReceiverStream(rx);
@ -234,6 +237,8 @@ where
bytes.extend(b);
}
tracing::debug!("Finished consuming field");
if let Some(error) = error {
return Err(error.into());
}
@ -382,6 +387,8 @@ where
}
}
tracing::debug!("Finished consuming multipart");
if let Some(e) = provided_error {
return Ok(Err(e));
}