Allow forEach consumer to have a Cache Injected

Cache Injection was purposely left out with distributed streams. This is due to map/reduce requiring CDI to do injection. Do we still want to do that or just do something simple like an extra interface?