Add helper bounds to OneOfSequentialFlow for better error messages

Author: HANDZCZ

src/flows/one_of_sequential_flow/builder.rs

@@ -5,19 +5,31 @@ use crate::{
     node::{Node, NodeOutput as NodeOutputStruct},
 };
 
-pub struct OneOfSequentialFlowBuilder<Input, Output, Error, NodeTypes = (), NodeIOETypes = ()> {
+pub struct OneOfSequentialFlowBuilder<Input, Output, Error, NodeTypes = (), NodeIOETypes = ()>
+where
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
+{
     _ioe: PhantomData<(Input, Output, Error)>,
     _nodes_io: PhantomData<NodeIOETypes>,
     nodes: NodeTypes,
 }
 
-impl<Input, Output, Error> Default for OneOfSequentialFlowBuilder<Input, Output, Error> {
+impl<Input, Output, Error> Default for OneOfSequentialFlowBuilder<Input, Output, Error>
+where
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
+{
     fn default() -> Self {
         Self::new()
     }
 }
 
-impl<Input, Output, Error> OneOfSequentialFlowBuilder<Input, Output, Error> {
+impl<Input, Output, Error> OneOfSequentialFlowBuilder<Input, Output, Error>
+where
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
+{
     #[must_use]
     pub fn new() -> Self {
         Self {
@@ -42,7 +54,9 @@ impl<Input, Output, Error> OneOfSequentialFlowBuilder<Input, Output, Error> {
         Input: Into<NodeInput>,
         NodeOutput: Into<Output>,
         NodeError: Into<Error>,
-        NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError> + Clone,
+        NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError>,
+        // Trait bounds for better and nicer errors
+        NodeType: Clone + Send + Sync,
     {
         OneOfSequentialFlowBuilder {
             _ioe: PhantomData,
@@ -60,6 +74,9 @@ impl<Input, Output, Error, NodeTypes, LastNodeIOETypes, OtherNodeIOETypes>
         NodeTypes,
         ChainLink<OtherNodeIOETypes, LastNodeIOETypes>,
     >
+where
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
 {
     #[allow(clippy::type_complexity)]
     pub fn add_node<NodeType, NodeInput, NodeOutput, NodeError>(
@@ -79,7 +96,9 @@ impl<Input, Output, Error, NodeTypes, LastNodeIOETypes, OtherNodeIOETypes>
         Input: Into<NodeInput>,
         NodeOutput: Into<Output>,
         NodeError: Into<Error>,
-        NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError> + Clone,
+        NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError>,
+        // Trait bounds for better and nicer errors
+        NodeType: Clone + Send + Sync,
     {
         OneOfSequentialFlowBuilder {
             _ioe: PhantomData,

src/flows/one_of_sequential_flow/flow.rs

@@ -14,7 +14,11 @@ pub struct OneOfSequentialFlow<Input, Output, Error, NodeTypes = (), NodeIOEType
     pub(super) nodes: Arc<NodeTypes>,
 }
 
-impl<Input, Output, Error> OneOfSequentialFlow<Input, Output, Error> {
+impl<Input, Output, Error> OneOfSequentialFlow<Input, Output, Error>
+where
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
+{
     #[must_use]
     pub fn builder() -> OneOfSequentialFlowBuilder<Input, Output, Error> {
         OneOfSequentialFlowBuilder::new()
@@ -25,6 +29,8 @@ impl<Input, Output, Error, NodeTypes, NodeIOETypes> Node<Input, NodeOutputStruct
     for OneOfSequentialFlow<Input, Output, Error, NodeTypes, NodeIOETypes>
 where
     NodeTypes: ChainRunOneOfSequential<Input, NodeResult<Output, Error>, NodeIOETypes>,
+    // Trait bounds for better and nicer errors
+    Input: Send + Clone,
 {
     fn run_with_storage(
         &mut self,