use core::{fmt, marker::PhantomData, num::NonZeroUsize, ops::ControlFlow};
use crate::{
DoubleEndedFallibleLender, ExactSizeFallibleLender, FallibleLend, FallibleLender,
FallibleLending, FusedFallibleLender, try_trait_v2::Try,
};
#[derive(Clone)]
#[must_use = "lenders are lazy and do nothing unless consumed"]
pub struct MapErr<E, L, F> {
pub(crate) lender: L,
f: F,
_marker: PhantomData<fn() -> E>,
}
impl<E, L: crate::FallibleLender, F> MapErr<E, L, F> {
#[inline(always)]
pub(crate) fn new(lender: L, f: F) -> Self {
let _ = L::__check_covariance(crate::CovariantProof::new());
Self {
lender,
f,
_marker: PhantomData,
}
}
#[inline(always)]
pub fn into_inner(self) -> L {
self.lender
}
#[inline(always)]
pub fn into_parts(self) -> (L, F) {
(self.lender, self.f)
}
}
impl<E, L: fmt::Debug, F> fmt::Debug for MapErr<E, L, F> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_struct("MapErr")
.field("lender", &self.lender)
.finish_non_exhaustive()
}
}
impl<'lend, E, L, F> FallibleLending<'lend> for MapErr<E, L, F>
where
L: FallibleLender,
{
type Lend = FallibleLend<'lend, L>;
}
impl<E, L, F> FallibleLender for MapErr<E, L, F>
where
F: FnMut(L::Error) -> E,
L: FallibleLender,
{
type Error = E;
crate::unsafe_assume_covariance_fallible!();
#[inline]
fn next(&mut self) -> Result<Option<FallibleLend<'_, Self>>, Self::Error> {
self.lender.next().map_err(&mut self.f)
}
#[inline(always)]
fn size_hint(&self) -> (usize, Option<usize>) {
self.lender.size_hint()
}
#[inline]
fn count(mut self) -> Result<usize, Self::Error>
where
Self: Sized,
{
self.lender.count().map_err(&mut self.f)
}
#[inline]
fn advance_by(&mut self, n: usize) -> Result<Result<(), NonZeroUsize>, Self::Error> {
self.lender.advance_by(n).map_err(&mut self.f)
}
#[inline]
fn nth(&mut self, n: usize) -> Result<Option<FallibleLend<'_, Self>>, Self::Error> {
self.lender.nth(n).map_err(&mut self.f)
}
#[inline]
fn last<'call>(&'call mut self) -> Result<Option<FallibleLend<'call, Self>>, Self::Error>
where
Self: Sized,
{
self.lender.last().map_err(&mut self.f)
}
#[inline]
fn try_fold<B, Fold, R>(&mut self, init: B, mut fold: Fold) -> Result<R, Self::Error>
where
Self: Sized,
Fold: FnMut(B, FallibleLend<'_, Self>) -> Result<R, Self::Error>,
R: Try<Output = B>,
{
let f = &mut self.f;
match self
.lender
.try_fold(init, |acc, x| Ok(super::try_fold_with(fold(acc, x))))
{
Ok(ControlFlow::Continue(acc)) => Ok(R::from_output(acc)),
Ok(ControlFlow::Break(r)) => r,
Err(e) => Err((f)(e)),
}
}
#[inline]
fn fold<B, Fold>(mut self, init: B, mut fold: Fold) -> Result<B, Self::Error>
where
Self: Sized,
Fold: FnMut(B, FallibleLend<'_, Self>) -> Result<B, Self::Error>,
{
let f = &mut self.f;
match self.lender.try_fold(init, |acc, x| match fold(acc, x) {
Ok(b) => Ok(ControlFlow::Continue(b)),
Err(e) => Ok(ControlFlow::Break(e)),
}) {
Ok(ControlFlow::Continue(acc)) => Ok(acc),
Ok(ControlFlow::Break(e)) => Err(e),
Err(e) => Err((f)(e)),
}
}
}
impl<E, L: DoubleEndedFallibleLender, F> DoubleEndedFallibleLender for MapErr<E, L, F>
where
F: FnMut(L::Error) -> E,
{
#[inline]
fn next_back(&mut self) -> Result<Option<FallibleLend<'_, Self>>, Self::Error> {
self.lender.next_back().map_err(&mut self.f)
}
#[inline]
fn advance_back_by(&mut self, n: usize) -> Result<Result<(), NonZeroUsize>, Self::Error> {
self.lender.advance_back_by(n).map_err(&mut self.f)
}
#[inline]
fn nth_back(&mut self, n: usize) -> Result<Option<FallibleLend<'_, Self>>, Self::Error> {
self.lender.nth_back(n).map_err(&mut self.f)
}
#[inline]
fn try_rfold<B, Fold, R>(&mut self, init: B, mut fold: Fold) -> Result<R, Self::Error>
where
Self: Sized,
Fold: FnMut(B, FallibleLend<'_, Self>) -> Result<R, Self::Error>,
R: Try<Output = B>,
{
let f = &mut self.f;
match self
.lender
.try_rfold(init, |acc, x| Ok(super::try_fold_with(fold(acc, x))))
{
Ok(ControlFlow::Continue(acc)) => Ok(R::from_output(acc)),
Ok(ControlFlow::Break(r)) => r,
Err(e) => Err((f)(e)),
}
}
#[inline]
fn rfold<B, Fold>(mut self, init: B, mut fold: Fold) -> Result<B, Self::Error>
where
Self: Sized,
Fold: FnMut(B, FallibleLend<'_, Self>) -> Result<B, Self::Error>,
{
let f = &mut self.f;
match self.lender.try_rfold(init, |acc, x| match fold(acc, x) {
Ok(b) => Ok(ControlFlow::Continue(b)),
Err(e) => Ok(ControlFlow::Break(e)),
}) {
Ok(ControlFlow::Continue(acc)) => Ok(acc),
Ok(ControlFlow::Break(e)) => Err(e),
Err(e) => Err((f)(e)),
}
}
}
impl<E, L, F> FusedFallibleLender for MapErr<E, L, F>
where
F: FnMut(L::Error) -> E,
L: FusedFallibleLender,
{
}
impl<E, L, F> ExactSizeFallibleLender for MapErr<E, L, F>
where
F: FnMut(L::Error) -> E,
L: ExactSizeFallibleLender,
{
#[inline(always)]
fn len(&self) -> usize {
self.lender.len()
}
#[inline(always)]
fn is_empty(&self) -> bool {
self.lender.is_empty()
}
}