Toggle navigation
Home
org.apache.usergrid.persistence.collection.MvccEntity to org.apache.usergrid.persistence.collection.MvccLogEntry
No. of Instances - 2
No. of Commits - 2
No. of Projects - {'usergrid'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
Func1<List<MvccEntity>,List<MvccEntity>>
to
Func1<List<MvccLogEntry>,List<MvccLogEntry>>
Add or Remove Method invocation
rx.Observable.from(entityVersions).subscribeOn(Schedulers.io()).buffer(serializationFig.getBufferSize()).map(new Func1<List<MvccLogEntry>,List<MvccLogEntry>>(){ @Override public List<MvccEntity> call( List<MvccEntity> entityList){ for ( MvccEntity entity : entityList) { eibatch.deindex(indexScope,entityId,entity.getVersion()); } eibatch.execute(); return entityList; } } ).toBlocking()
to
rx.Observable.from(entityVersions).buffer(serializationFig.getBufferSize()).map(new Func1<List<MvccLogEntry>,List<MvccLogEntry>>(){ @Override public List<MvccLogEntry> call( List<MvccLogEntry> entityList){ for ( MvccLogEntry entity : entityList) { eibatch.deindex(indexScope,entityId,entity.getVersion()); } eibatch.execute(); return entityList; } } ).toBlocking()