#include <dataflow_lite/dataflow/observed_queue.h>#include <dataflow_lite/dataflow/sink.h>#include <future>#include <memory>

Go to the source code of this file.
Classes | |
| class | Aws::DataFlow::BasicTask< T > |
| class | Aws::DataFlow::IPublisher< T > |
| class | Aws::DataFlow::Task< T > |
Namespaces | |
| Aws | |
| Aws::DataFlow | |
Typedefs | |
| template<typename Status , typename T > | |
| using | Aws::DataFlow::UploadStatusFunction = std::function< void(const Status &upload_status, const T &message)> |
Enumerations | |
| enum | Aws::DataFlow::UploadStatus { Aws::DataFlow::UNKNOWN, Aws::DataFlow::FAIL, Aws::DataFlow::SUCCESS, Aws::DataFlow::INVALID_DATA } |