#include <dataflow_lite/dataflow/observed_queue.h>#include <dataflow_lite/dataflow/pipeline.h>#include <dataflow_lite/dataflow/priority_options.h>#include <dataflow_lite/dataflow/queue_monitor.h>#include <dataflow_lite/dataflow/sink.h>#include <dataflow_lite/dataflow/source.h>#include <dataflow_lite/dataflow/status_monitor.h>
Include dependency graph for dataflow.h:
Go to the source code of this file.
Namespaces | |
| Aws | |
| Aws::DataFlow | |
Functions | |
| template<typename T , class O > | |
| std::enable_if< std::is_base_of< Sink< T >, O >::value, std::shared_ptr< O > >::type | Aws::DataFlow::operator>> (OutputStage< T > &output_stage, std::shared_ptr< O > sink) |
| template<typename T , class O > | |
| std::enable_if< std::is_base_of< QueueDemux< T >, O >::value, std::shared_ptr< O > >::type | Aws::DataFlow::operator>> (std::tuple< std::shared_ptr< ObservedQueue< T >>, PriorityOptions > observed_queue, std::shared_ptr< O > sink) |
| template<typename T > | |
| std::tuple< std::shared_ptr< ObservedQueue< T > >, PriorityOptions > | Aws::DataFlow::operator>> (std::shared_ptr< ObservedQueue< T >> observed_queue, PriorityLevel level) |
| template<typename O , class T , class = typename std::enable_if<std::is_base_of<Source<T>, O>::value, std::shared_ptr<O>>::type> | |
| InputStage< T > & | Aws::DataFlow::operator>> (std::shared_ptr< O > source, InputStage< T > &inputStage) |