I can't figure out how these event handlers fit into the pipeline?
I've be trying to customise aster to not be hardcoded to only work with files.
I'd like to make my own custom runner, but not sure where I should call/trigger equivalent events like onComplete etc. Is it the Observable created for each read file?
Please advice. Thanks!