//! Implementation of [`MonadFail`] for [`Result`]. //! //! If any of the input values are [`Err`], you can expect the output to be [`Err`] as well. //! That includes //! [`ResultInstance::replace`] and [`ResultInstance::discard_first`]/[`ResultInstance::discard_second`], //! even if the value of the option would be ignored. //! //! For [`Option`] alternative see [`super::option`] use crate::func::*; #[derive(SharedFunctor, CovariantFunctor)] pub struct ResultInstance(E); impl WeakFunctor for ResultInstance { type F<'a, A: 'a> = Result where Self: 'a; } impl Functor for ResultInstance { fn fmap<'a, A: 'a, B: 'a>(f: impl 'a + FnOnce(A) -> B, fa: Self::F<'a, A>) -> Self::F<'a, B> where Self: 'a, { fa.map(f) } fn replace<'a, A: 'a, B: 'a>(fa: Self::F<'a, A>, b: B) -> Self::F<'a, B> where Self: 'a, { fa?; Self::pure(b) } fn void<'a, A: 'a>(fa: Self::F<'a, A>) -> Self::F<'a, ()> where Self: 'a, { fa?; Self::pure(()) } } impl Pure for ResultInstance { fn pure<'a, A: 'a>(a: A) -> Self::F<'a, A> where Self: 'a, { Ok(a) } } impl ApplicativeSeq for ResultInstance { fn seq<'a, A: 'a, B: 'a>( ff: Self::F<'a, impl 'a + FnOnce(A) -> B>, fa: Self::F<'a, A>, ) -> Self::F<'a, B> where Self: 'a, { Self::pure(ff?(fa?)) } } impl ApplicativeLA2 for ResultInstance { fn la2<'a, A: 'a, B: 'a, C: 'a>( f: impl 'a + FnOnce(A, B) -> C, fa: Self::F<'a, A>, fb: Self::F<'a, B>, ) -> Self::F<'a, C> where Self: 'a, { Self::pure(f(fa?, fb?)) } } impl ApplicativeTuple for ResultInstance { fn tuple<'a, A: 'a, B: 'a>((fa, fb): (Self::F<'a, A>, Self::F<'a, B>)) -> Self::F<'a, (A, B)> where Self: 'a, { Self::pure((fa?, fb?)) } } impl ApplicativeSelect for ResultInstance {} impl Applicative for ResultInstance { fn discard_first<'a, A: 'a, B: 'a>(fa: Self::F<'a, A>, fb: Self::F<'a, B>) -> Self::F<'a, B> where Self: 'a, { fa?; fb } fn discard_second<'a, A: 'a, B: 'a>(fa: Self::F<'a, A>, fb: Self::F<'a, B>) -> Self::F<'a, A> where Self: 'a, { fb?; fa } } impl<'a, E: 'a> Monad<'a> for ResultInstance { fn bind( fa: Self::F<'a, A>, f: impl 'a + FnOnce(A) -> Self::F<'a, B>, ) -> Self::F<'a, B> { f(fa?) } fn iterate(mut f: impl Iterative<'a, T = Self, B = B>) -> Self::F<'a, B> { loop { match f.next()? { ControlFlow::Continue(next_f) => f = next_f, ControlFlow::Break(b) => return Self::pure(b), } } } fn join(ffa: Self::F<'a, Self::F<'a, A>>) -> Self::F<'a, A> { ffa? } } impl LocalFunctor for ResultInstance { fn unstuff<'a, A: 'a, B: 'a>( state: Self::F<'a, ControlFlow>, ) -> ControlFlow, A> where Self: 'a, { match state { Ok(ControlFlow::Continue(a)) => ControlFlow::Continue(a), Ok(ControlFlow::Break(b)) => ControlFlow::Break(Ok(b)), Err(e) => ControlFlow::Break(Err(e)), } } fn stuff<'a, A: 'a, T: 'a + Pure>(fa: Self::F<'a, T::F<'a, A>>) -> T::F<'a, Self::F<'a, A>> where Self: 'a, { match fa { Ok(ua) => T::fmap(Ok, ua), Err(e) => T::pure(Err(e)), } } } impl<'a, E: 'a> Fail<'a, E> for ResultInstance { fn fail(e: E) -> Self::F<'a, A> { Err(e) } } pub struct ResultFailAny; trait ResultExt<'a, A: 'a, E0: 'a>: 'a { fn bind_err(self, f: impl 'a + FnOnce(E0) -> Result) -> Result; } impl<'a, A: 'a, E0: 'a> ResultExt<'a, A, E0> for Result { fn bind_err(self, f: impl 'a + FnOnce(E0) -> Result) -> Result { match self { Ok(a) => Ok(a), Err(e) => f(e), } } } impl<'a> MonadFailAny<'a> for ResultFailAny { type W = ResultInstance; type T = instances::solo::SoloInstance; fn unstuff(wa: WrapE<'a, A, E, Self>) -> Wrap<'a, Result, Self::T> { wa } fn stuff(fa: Wrap<'a, Result, Self::T>) -> WrapE<'a, A, E, Self> { fa } fn map_err( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(E0) -> E1, ) -> WrapE<'a, A, E1, Self> { wa.map_err(f) } fn bind_err( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(E0) -> WrapE<'a, A, E1, Self>, ) -> WrapE<'a, A, E1, Self> { wa.bind_err(f) } fn bind( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(Result) -> WrapE<'a, B, E1, Self>, ) -> WrapE<'a, B, E1, Self> { f(wa) } fn rotate_out( wa: WrapE<'a, Result, E0, Self>, ) -> WrapE<'a, A, Result, Self> { match wa { Ok(Ok(a)) => Ok(a), Ok(Err(e)) => Err(Ok(e)), Err(e) => Err(Err(e)), } } } pub struct ResultFailOver(T); impl<'a, T: Monad<'a>> MonadFailAny<'a> for ResultFailOver { type W = super::composition::CompositionInstance>; type T = T; fn unstuff(wa: WrapE<'a, A, E, Self>) -> Wrap<'a, Result, Self::T> { wa } fn stuff(fa: Wrap<'a, Result, Self::T>) -> WrapE<'a, A, E, Self> { fa } fn map_err( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(E0) -> E1, ) -> WrapE<'a, A, E1, Self> { T::fmap(|a| a.map_err(f), wa) } fn bind_err( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(E0) -> WrapE<'a, A, E1, Self>, ) -> WrapE<'a, A, E1, Self> { T::bind(wa, |a| match a { Ok(a) => T::pure(Ok(a)), Err(e) => f(e), }) } fn bind( wa: WrapE<'a, A, E0, Self>, f: impl 'a + FnOnce(Result) -> WrapE<'a, B, E1, Self>, ) -> WrapE<'a, B, E1, Self> { T::bind(wa, f) } fn rotate_out( wa: WrapE<'a, Result, E0, Self>, ) -> WrapE<'a, A, Result, Self> { T::fmap(::rotate_out, wa) } }