warp/filter/
map_err.rs

1use std::future::Future;
2use std::pin::Pin;
3use std::task::{Context, Poll};
4
5use futures_util::TryFuture;
6use pin_project::pin_project;
7
8use super::{Filter, FilterBase, Internal};
9use crate::reject::IsReject;
10
11#[derive(Clone, Copy, Debug)]
12pub struct MapErr<T, F> {
13    pub(super) filter: T,
14    pub(super) callback: F,
15}
16
17impl<T, F, E> FilterBase for MapErr<T, F>
18where
19    T: Filter,
20    F: Fn(T::Error) -> E + Clone + Send,
21    E: IsReject,
22{
23    type Extract = T::Extract;
24    type Error = E;
25    type Future = MapErrFuture<T, F>;
26    #[inline]
27    fn filter(&self, _: Internal) -> Self::Future {
28        MapErrFuture {
29            extract: self.filter.filter(Internal),
30            callback: self.callback.clone(),
31        }
32    }
33}
34
35#[allow(missing_debug_implementations)]
36#[pin_project]
37pub struct MapErrFuture<T: Filter, F> {
38    #[pin]
39    extract: T::Future,
40    callback: F,
41}
42
43impl<T, F, E> Future for MapErrFuture<T, F>
44where
45    T: Filter,
46    F: Fn(T::Error) -> E,
47{
48    type Output = Result<T::Extract, E>;
49
50    #[inline]
51    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
52        self.as_mut()
53            .project()
54            .extract
55            .try_poll(cx)
56            .map_err(|err| (self.callback)(err))
57    }
58}
warp/filter/map_err.rs

warp/filter/
map_err.rs
