add RichFlowProcess which wraps the FlowProcess and allows you to incrementCounters and keepAlive from anonymous functions without creating new cascading operations