feat(FilterOk): implement DoubleEndedIterator

Refs: #947

Author: Xenira

benches/specializations.rs

@@ -639,6 +639,7 @@ bench_specializations! {
  v.iter().copied().map_ok(|x| x + 1)
  }
  filter_ok {
+ DoubleEndedIterator
  {
  let v = black_box((0_u32..1024)
  .map(|x| if x % 2 == 1 { Err(x) } else { Ok(x) })

src/adaptors/mod.rs

@@ -936,6 +936,30 @@ where
  }
 }
 
+impl<I, F, T, E> DoubleEndedIterator for FilterOk<I, F>
+where
+ I: DoubleEndedIterator<Item = Result<T, E>>,
+ F: FnMut(&T) -> bool,
+{
+ fn next_back(&mut self) -> Option<Self::Item> {
+ let f = &mut self.f;
+ self.iter.rfind(|res| match res {
+ Ok(t) => f(t),
+ _ => true,
+ })
+ }
+
+ fn rfold<Acc, Fold>(self, init: Acc, fold_f: Fold) -> Acc
+ where
+ Fold: FnMut(Acc, Self::Item) -> Acc,
+ {
+ let mut f = self.f;
+ self.iter
+ .filter(|v| v.as_ref().map(&mut f).unwrap_or(true))
+ .rfold(init, fold_f)
+ }
+}
+
 impl<I, F, T, E> FusedIterator for FilterOk<I, F>
 where
  I: FusedIterator<Item = Result<T, E>>,

tests/specializations.rs

@@ -447,7 +447,9 @@ quickcheck! {
  }
 
  fn filter_ok(v: Vec<Result<u8, char>>) -> () {
- test_specializations(&v.into_iter().filter_ok(|&i| i < 20));
+ let it = v.into_iter().filter_ok(|&i| i < 20);
+ test_specializations(&it);
+ test_double_ended_specializations(&it);
  }
 
  fn filter_map_ok(v: Vec<Result<u8, char>>) -> () {