ADAP: the Awesome Data Augmentation Pipeline

This library allows you to create a data processing stream where elements will go accross nodes applying data processing rules to include data, emit new elements, or modify it according to locally present data.

• Adap.Stream will create the stream taking an input stream and a module implementing do_emit/2 to define the processing pipeline of each element.
• Adap.Unit are processes started on demand where elements can be routed to use locally constructed datas
• Adap.Piper allows to create a data processing pipeline (module implementing do_emit/2) as :
  • successive matching rules
  • external dependencies for each rule as a Adap.Unit spec

See an example usage in Adap.Piper.