Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
147 changes: 147 additions & 0 deletions library/core/src/ops/control_flow.rs
Original file line number Diff line number Diff line change
Expand Up @@ -187,6 +187,80 @@ impl<B, C> ControlFlow<B, C> {
}
}

/// Converts the `ControlFlow` into an `Result` which is `Ok` if the
/// `ControlFlow` was `Break` and `Err` if otherwise.
///
/// # Examples
///
/// ```
/// #![feature(control_flow_ok)]
///
/// use std::ops::ControlFlow;
///
/// struct TreeNode<T> {
/// value: T,
/// left: Option<Box<TreeNode<T>>>,
/// right: Option<Box<TreeNode<T>>>,
/// }
///
/// impl<T> TreeNode<T> {
/// fn find<'a>(&'a self, mut predicate: impl FnMut(&T) -> bool) -> Result<&'a T, ()> {
/// let mut f = |t: &'a T| -> ControlFlow<&'a T> {
/// if predicate(t) {
/// ControlFlow::Break(t)
/// } else {
/// ControlFlow::Continue(())
/// }
/// };
///
/// self.traverse_inorder(&mut f).break_ok()
/// }
///
/// fn traverse_inorder<'a, B>(
/// &'a self,
/// f: &mut impl FnMut(&'a T) -> ControlFlow<B>,
/// ) -> ControlFlow<B> {
/// if let Some(left) = &self.left {
/// left.traverse_inorder(f)?;
/// }
/// f(&self.value)?;
/// if let Some(right) = &self.right {
/// right.traverse_inorder(f)?;
/// }
/// ControlFlow::Continue(())
/// }
///
/// fn leaf(value: T) -> Option<Box<TreeNode<T>>> {
/// Some(Box::new(Self {
/// value,
/// left: None,
/// right: None,
/// }))
/// }
/// }
///
/// let node = TreeNode {
/// value: 0,
/// left: TreeNode::leaf(1),
/// right: Some(Box::new(TreeNode {
/// value: -1,
/// left: TreeNode::leaf(5),
/// right: TreeNode::leaf(2),
/// })),
/// };
///
/// let res = node.find(|val: &i32| *val > 3);
/// assert_eq!(res, Ok(&5));
/// ```
#[inline]
#[unstable(feature = "control_flow_ok", issue = "140266")]
pub fn break_ok(self) -> Result<B, C> {
match self {
ControlFlow::Continue(c) => Err(c),
ControlFlow::Break(b) => Ok(b),
}
}

/// Maps `ControlFlow<B, C>` to `ControlFlow<T, C>` by applying a function
/// to the break value in case it exists.
#[inline]
Expand Down Expand Up @@ -218,6 +292,79 @@ impl<B, C> ControlFlow<B, C> {
}
}

/// Converts the `ControlFlow` into an `Result` which is `Ok` if the
/// `ControlFlow` was `Continue` and `Err` if otherwise.
///
/// # Examples
///
/// ```
/// #![feature(control_flow_ok)]
///
/// use std::ops::ControlFlow;
///
/// struct TreeNode<T> {
/// value: T,
/// left: Option<Box<TreeNode<T>>>,
/// right: Option<Box<TreeNode<T>>>,
/// }
///
/// impl<T> TreeNode<T> {
/// fn validate<B>(&self, f: &mut impl FnMut(&T) -> ControlFlow<B>) -> Result<(), B> {
/// self.traverse_inorder(f).continue_ok()
/// }
///
/// fn traverse_inorder<B>(&self, f: &mut impl FnMut(&T) -> ControlFlow<B>) -> ControlFlow<B> {
/// if let Some(left) = &self.left {
/// left.traverse_inorder(f)?;
/// }
/// f(&self.value)?;
/// if let Some(right) = &self.right {
/// right.traverse_inorder(f)?;
/// }
/// ControlFlow::Continue(())
/// }
///
/// fn leaf(value: T) -> Option<Box<TreeNode<T>>> {
/// Some(Box::new(Self {
/// value,
/// left: None,
/// right: None,
/// }))
/// }
/// }
///
/// let node = TreeNode {
/// value: 0,
/// left: TreeNode::leaf(1),
/// right: Some(Box::new(TreeNode {
/// value: -1,
/// left: TreeNode::leaf(5),
/// right: TreeNode::leaf(2),
/// })),
/// };
///
/// let res = node.validate(&mut |val| {
/// if *val < 0 {
/// return ControlFlow::Break("negative value detected");
/// }
///
/// if *val > 4 {
/// return ControlFlow::Break("too big value detected");
/// }
///
/// ControlFlow::Continue(())
/// });
/// assert_eq!(res, Err("too big value detected"));
/// ```
#[inline]
#[unstable(feature = "control_flow_ok", issue = "140266")]
pub fn continue_ok(self) -> Result<C, B> {
match self {
ControlFlow::Continue(c) => Ok(c),
ControlFlow::Break(b) => Err(b),
}
}

/// Maps `ControlFlow<B, C>` to `ControlFlow<B, T>` by applying a function
/// to the continue value in case it exists.
#[inline]
Expand Down
1 change: 1 addition & 0 deletions library/coretests/tests/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
#![feature(const_ref_cell)]
#![feature(const_result_trait_fn)]
#![feature(const_trait_impl)]
#![feature(control_flow_ok)]
#![feature(core_float_math)]
#![feature(core_intrinsics)]
#![feature(core_intrinsics_fallbacks)]
Expand Down
12 changes: 12 additions & 0 deletions library/coretests/tests/ops/control_flow.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,3 +16,15 @@ fn control_flow_discriminants_match_result() {
discriminant_value(&Result::<i32, i32>::Ok(3)),
);
}

#[test]
fn control_flow_break_ok() {
assert_eq!(ControlFlow::<char, i32>::Break('b').break_ok(), Ok('b'));
assert_eq!(ControlFlow::<char, i32>::Continue(3).break_ok(), Err(3));
}

#[test]
fn control_flow_continue_ok() {
assert_eq!(ControlFlow::<char, i32>::Break('b').continue_ok(), Err('b'));
assert_eq!(ControlFlow::<char, i32>::Continue(3).continue_ok(), Ok(3));
}