summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorLee Bousfield <ljbousfield@gmail.com>2017-10-03 12:03:03 -0600
committerLee Bousfield <ljbousfield@gmail.com>2017-10-03 12:03:03 -0600
commit25a7b0e45e857fc7ea79c517d73ae773d8f82048 (patch)
treee480c1af34bed320331ae1dce6140a925a0ec2f5
parente668b6818c61f8f9f51821d6cda79a160d1fce75 (diff)
Add into_failable and as_failable methods
-rw-r--r--src/filter.rs40
-rw-r--r--src/ops/failable.rs51
-rw-r--r--src/ops/mod.rs1
3 files changed, 92 insertions, 0 deletions
diff --git a/src/filter.rs b/src/filter.rs
index d2748bd..9d92c6f 100644
--- a/src/filter.rs
+++ b/src/filter.rs
@@ -14,6 +14,7 @@ pub use ops::not::Not;
pub use ops::xor::XOr;
pub use ops::or::Or;
pub use ops::map::MapInput;
+pub use ops::failable::{IntoFailable, AsFailable};
/// Trait for converting something into a Filter
pub trait IntoFilter<N> {
@@ -281,6 +282,45 @@ pub trait Filter<N> {
{
MapInput::new(self, map)
}
+
+ /// Helper to transform a filter into a FailableFilter
+ ///
+ /// ```
+ /// use filters::filter::Filter;
+ /// use filters::failable::filter::FailableFilter;
+ ///
+ /// let a = (|&a: &usize| { a > 5 });
+ /// let a = a.into_failable();
+ ///
+ /// assert_eq!(a.filter(&3), Ok(false));
+ /// assert_eq!(a.filter(&5), Ok(false));
+ /// assert_eq!(a.filter(&7), Ok(true));
+ /// assert_eq!(a.filter(&9), Ok(true));
+ /// ```
+ fn into_failable(self) -> IntoFailable<Self, ()>
+ where Self: Sized
+ {
+ IntoFailable::new(self)
+ }
+
+ /// Helper to borrow a filter as a FailbleFilter
+ ///
+ /// ```
+ /// use filters::filter::Filter;
+ /// use filters::failable::filter::FailableFilter;
+ ///
+ /// let a = (|&a: &usize| { a > 5 });
+ /// let b = a.as_failable();
+ ///
+ /// assert_eq!(a.filter(&3), false);
+ /// assert_eq!(b.filter(&3), Ok(false));
+ /// assert_eq!(a.filter(&7), true);
+ /// assert_eq!(b.filter(&7), Ok(true));
+ fn as_failable<'a>(&'a self) -> AsFailable<'a, Self, ()>
+ where Self: 'a
+ {
+ AsFailable::new(self)
+ }
}
diff --git a/src/ops/failable.rs b/src/ops/failable.rs
new file mode 100644
index 0000000..5a92ba7
--- /dev/null
+++ b/src/ops/failable.rs
@@ -0,0 +1,51 @@
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+//
+
+//! Filter -> FailableFilter implementations
+//!
+//! Will be automatically included when incluing `filter::Filter`, so importing this module
+//! shouldn't be necessary.
+//!
+use std::marker::PhantomData;
+
+use filter::Filter;
+use failable::filter::FailableFilter;
+
+#[must_use = "filters are lazy and do nothing unless consumed"]
+#[derive(Clone)]
+pub struct IntoFailable<F, E>(F, PhantomData<E>);
+
+impl<F, E> IntoFailable<F, E> {
+ pub fn new(a: F) -> IntoFailable<F, E> {
+ IntoFailable(a, PhantomData)
+ }
+}
+
+impl<F, N, E> FailableFilter<N, E> for IntoFailable<F, E>
+ where F: Filter<N>,
+{
+ fn filter(&self, e: &N) -> Result<bool, E> {
+ Ok(self.0.filter(e))
+ }
+}
+
+#[must_use = "filters are lazy and do nothing unless consumed"]
+#[derive(Clone)]
+pub struct AsFailable<'a, F: 'a + ?Sized, E>(&'a F, PhantomData<E>);
+
+impl<'a, F: 'a + ?Sized, E> AsFailable<'a, F, E> {
+ pub fn new(a: &'a F) -> AsFailable<F, E> {
+ AsFailable(a, PhantomData)
+ }
+}
+
+impl<'a, F, N, E> FailableFilter<N, E> for AsFailable<'a, F, E>
+ where F: Filter<N> + 'a + ?Sized,
+{
+ fn filter(&self, e: &N) -> Result<bool, E> {
+ Ok(self.0.filter(e))
+ }
+}
diff --git a/src/ops/mod.rs b/src/ops/mod.rs
index a5dd6b6..3964f88 100644
--- a/src/ops/mod.rs
+++ b/src/ops/mod.rs
@@ -10,3 +10,4 @@ pub mod not;
pub mod or;
pub mod xor;
pub mod map;
+pub mod failable;