Toggle navigation
Home
CacheEntryUpdatedListener<K, V> to CacheEntryUpdatedListener
No. of Instances - 3
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: External -> External
Mapping:
Cascading Type Change (Different)
Iterable<CacheEntryEvent<? extends K,? extends V>>
to
Iterable<CacheEntryEvent>
Update Anonymous class
{ @Override public Iterator<CacheEntryEvent<? extends K,? extends V>> iterator(){ return new Iterator<CacheEntryEvent<? extends K,? extends V>>(){ private CacheContinuousQueryEvent<? extends K,? extends V> next; { advance(); } @Override public boolean hasNext(){ return next != null; } @Override public CacheEntryEvent<? extends K,? extends V> next(){ if (!hasNext()) throw new NoSuchElementException(); CacheEntryEvent<? extends K,? extends V> next0=next; advance(); return next0; } @Override public void remove(){ throw new UnsupportedOperationException(); } private void advance(){ next=null; while (next == null) { if (!it.hasNext()) break; GridCacheEntryEx e=it.next(); next=new CacheContinuousQueryEvent<>(cctx.kernalContext().cache().jcache(cctx.name()),cctx,new CacheContinuousQueryEntry(cctx.cacheId(),CREATED,e.key(),e.rawGet(),null)); if (rmtFilter != null && !rmtFilter.evaluate(next)) next=null; } } } ; } }
to
{ @Override public Iterator<CacheEntryEvent> iterator(){ return new Iterator<CacheEntryEvent>(){ private CacheContinuousQueryEvent next; { advance(); } @Override public boolean hasNext(){ return next != null; } @Override public CacheEntryEvent next(){ if (!hasNext()) throw new NoSuchElementException(); CacheEntryEvent next0=next; advance(); return next0; } @Override public void remove(){ throw new UnsupportedOperationException(); } private void advance(){ next=null; while (next == null) { if (!it.hasNext()) break; GridCacheEntryEx e=it.next(); next=new CacheContinuousQueryEvent<>(cctx.kernalContext().cache().jcache(cctx.name()),cctx,new CacheContinuousQueryEntry(cctx.cacheId(),CREATED,e.key(),e.rawGet(),null)); if (rmtFilter != null && !rmtFilter.evaluate(next)) next=null; } } } ; } }