#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 } |