59 const std::string& processor_id,
60 const std::string& destination_url,
72 const std::string& substream_name,
73 const std::string& processor_id,
74 const std::string& destination_url,
83 void process(
const std::function<
bool(
double)>& progress_handler = {});
86 std::shared_ptr<adtf_file::Reader> _reader;
89 using SubstreamsInType = std::unordered_map<std::string, adtf_file::adtf3::SubstreamProperties>;
91 struct SubstreamProcessor
93 std::string processor_id;
95 std::string destination_url;
96 std::shared_ptr<Processor> processor;
103 std::unordered_map<uint16_t, std::unordered_map<std::string, SubstreamProcessor>> _processors;
108 bool use_substream_id;
109 std::shared_ptr<const adtf_file::StreamType> initial_type;
110 std::unordered_map<uint32_t, std::shared_ptr<Processor>> processors;
112 std::unordered_map<uint16_t, InputStream> _input_streams;
class to create or read a file item. This file item is either a sample, streamtype or trigger.
Definition: reader.h:156
class to create and describe a stream within a adtf_file::Reader. Each stream has an identifier strea...
Definition: reader.h:134
Definition: demultiplexer.h:41
void process(const std::function< bool(double)> &progress_handler={})
void addProcessor(const std::string &stream_name, const std::string &substream_name, const std::string &processor_id, const std::string &destination_url, const adtf_file::Configuration &configuration)
Demultiplexer(std::shared_ptr< adtf_file::Reader > reader, const ProcessorFactories &processor_factories)
void addProcessor(const std::string &stream_name, const std::string &processor_id, const std::string &destination_url, const adtf_file::Configuration &configuration)
Definition: processor.h:128
std::unordered_map< std::string, PropertyValue > Configuration
Configuration class as set of key - property value pairs This configuration is used to adjust the rea...
Definition: configuration.h:143
namespace for ADTF DAT Processing library.
Definition: ddl_helpers.h:38