I'd also like to see some versions for the common cases of counting the current stream or some subset of it... something like

````scala
pipe.incrementCounter("myjob.items") //increment by 1L for each item
pipe.incrementCounterWhere("myjob.items"){t => t.foo > bar} //increment by 1L for each item that passes the predicate
````