Skip to content

Commit f399e2b

Browse files
committed
Remove map_err that isn't needed anymore
1 parent 546f57e commit f399e2b

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/api/downloader.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,9 +142,7 @@ async fn handle_download_split_impl(
142142
let hash = request.hash;
143143
let (tx, rx) = tokio::sync::mpsc::channel::<(usize, DownloadProgessItem)>(16);
144144
progress_tx.send(rx).await.ok();
145-
let sink = TokioMpscSenderSink(tx)
146-
.with_map_err(|_| irpc::channel::SendError::ReceiverClosed)
147-
.with_map(move |x| (id, x));
145+
let sink = TokioMpscSenderSink(tx).with_map(move |x| (id, x));
148146
let res = execute_get(&pool, Arc::new(request), &providers, &store, sink).await;
149147
(hash, res)
150148
}

0 commit comments

Comments
 (0)