First version of end event
Implemented next/complete counting approach to measuring flow endedness