Operators should report to the interested parties about their events, such as beforeStart, onError, afterStop
Isn't this something an application should construct over the basic dataflow framework rather than be something inherent in the core framework itself?
We may also ned to enable custom events to be fired from operator's body and caught by event handlers.
Isn't this something an application should construct over the basic dataflow framework rather than be something inherent in the core framework itself?