code: @Inject
     public void inject(Cache<K, V> cache) {
        // We need to unwrap the cache as a local stream should only deal with BOXED values and obviously only
        // with local entries.  Any mappings will be provided by the originator node in their intermediate operation
        // stack in the operation itself.
        // Also this class manages iterations that were called for remotely so make sure our commands know this
        this.cache = AbstractDelegatingCache.unwrapCache(cache).getAdvancedCache().withFlags(Flag.CACHE_MODE_LOCAL,
              Flag.REMOTE_ITERATION);
     }
docs: Injects the cache - unfortunately this cannot be in start. Tests will rewire certain components which will in
  turn reinject the cache, but they won't call the start method! If the latter is fixed we can add this to start
  method and add @Inject to the variable.
  @param cache