fix: Ignore failure to send errors over a channel

pull/24376/head
Carol (Nichols || Goulding) 2021-08-12 15:05:23 -04:00
parent f3b23990c7
commit 927d947005
1 changed files with 2 additions and 2 deletions

View File

@ -118,11 +118,11 @@ impl IoxObjectStore {
tokio::spawn(async move {
match inner.list(prefix.as_ref()).await {
Err(e) => {
tx.send(Err(e)).await.expect("sending over channel failed");
let _ = tx.send(Err(e)).await;
}
Ok(mut stream) => {
while let Some(list) = stream.next().await {
tx.send(list).await.expect("sending over channel failed");
let _ = tx.send(list).await;
}
}
}