dataflow_cpp: added operator to directly connect output 0 to input 0

dataflow_cpp/include/embb/dataflow/internal/constant_source.h

@@ -68,6 +68,11 @@ class ConstantSource
   typename TypeAt<typename OutputsType::Types, Index>::Result & GetOutput() {
   typename TypeAt<typename OutputsType::Types, Index>::Result & GetOutput() {
     return outputs_.template Get<Index>();
     return outputs_.template Get<Index>();
   }
   }
+
+  template <typename T>
+  void operator >> (T & target) {
+    GetOutput<0>() >> target.GetInput<0>();
+  }
 };
 };
 
 
 } // namespace internal
 } // namespace internal

dataflow_cpp/include/embb/dataflow/internal/process.h

@@ -98,6 +98,11 @@ class Process< Slices, Serial, Inputs<Slices, I1, I2, I3, I4, I5>,
     return outputs_.template Get<Index>();
     return outputs_.template Get<Index>();
   }
   }
 
 
+  template <typename T>
+  void operator >> (T & target) {
+    GetOutput<0>() >> target.GetInput<0>();
+  }
+
   virtual void OnClock(int clock) {
   virtual void OnClock(int clock) {
     const int idx = clock % Slices;
     const int idx = clock % Slices;
     if (!inputs_.AreAtClock(clock))
     if (!inputs_.AreAtClock(clock))

dataflow_cpp/include/embb/dataflow/internal/select.h

@@ -99,6 +99,11 @@ class Select
     return outputs_.template Get<Index>();
     return outputs_.template Get<Index>();
   }
   }
 
 
+  template <typename T>
+  void operator >> (T & target) {
+    GetOutput<0>() >> target.GetInput<0>();
+  }
+
   virtual void OnClock(int clock) {
   virtual void OnClock(int clock) {
     //const int idx = clock % Slices;
     //const int idx = clock % Slices;
     if (!inputs_.AreAtClock(clock))
     if (!inputs_.AreAtClock(clock))

dataflow_cpp/include/embb/dataflow/internal/source.h

@@ -81,6 +81,11 @@ class Source< Slices, Outputs<Slices, O1, O2, O3, O4, O5> >
     return outputs_.template Get<Index>();
     return outputs_.template Get<Index>();
   }
   }
 
 
+  template <typename T>
+  void operator >> (T & target) {
+    GetOutput<0>() >> target.GetInput<0>();
+  }
+
  private:
  private:
   OutputsType outputs_;
   OutputsType outputs_;
   ExecutorType executor_;
   ExecutorType executor_;

dataflow_cpp/include/embb/dataflow/internal/switch.h

@@ -96,6 +96,11 @@ class Switch
     return outputs_.template Get<Index>();
     return outputs_.template Get<Index>();
   }
   }
 
 
+  template <typename T>
+  void operator >> (T & target) {
+    GetOutput<0>() >> target.GetInput<0>();
+  }
+
   virtual void OnClock(int clock) {
   virtual void OnClock(int clock) {
     //const int idx = clock % Slices;
     //const int idx = clock % Slices;
     if (!inputs_.AreAtClock(clock))
     if (!inputs_.AreAtClock(clock))

dataflow_cpp/include/embb/dataflow/network.h

@@ -235,6 +235,14 @@ class Network {
      */
      */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**
@@ -315,6 +323,14 @@ class Network {
     */
     */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**
@@ -385,6 +401,14 @@ class Network {
      */
      */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**
@@ -455,6 +479,14 @@ class Network {
      */
      */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**
@@ -588,6 +620,14 @@ class Network {
      */
      */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**
@@ -639,6 +679,14 @@ class Network {
      */
      */
     template <int Index>
     template <int Index>
     typename OutputsType::Types<Index>::Result & GetOutput();
     typename OutputsType::Types<Index>::Result & GetOutput();
+
+    /**
+     * Connects output port 0 to input port 0 of \c target.
+     * \param target Process to connect to.
+     * \tparam T Type of target process.
+     */
+    template <typename T>
+    void operator >> (T & target);
   };
   };
 
 
   /**
   /**

doc/examples/dataflow/dataflow_connect-snippet.h

-  read.GetOutput<0>() >> replace.GetInput<0>();
-  replace.GetOutput<0>() >> write.GetInput<0>();
+  read >> replace;
+  replace >> write;