Toggle navigation
Home
org.apache.usergrid.persistence.core.rx.AllEntitiesInSystemObservable to org.apache.usergrid.corepersistence.rx.impl.AllEntitiesInSystemImpl
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'usergrid'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
Action1<ApplicationEntityGroup<CollectionScope>>
to
Action1<EntityIdScope>
Add or Remove Method invocation
allEntitiesInSystemObservableImpl.getAllEntitiesInSystem(1000).doOnNext(new Action1<EntityIdScope>(){ @Override public void call( final ApplicationEntityGroup<CollectionScope> entity){ assertNotNull(entity); assertNotNull(entity.applicationScope); assertNotNull(entity.entityIds); if (!applicationId.equals(entity.applicationScope.getApplication())) { return; } for ( EntityIdScope<CollectionScope> idScope : entity.entityIds) { if (idScope.getId().getType().equals(type1)) { assertTrue("Element should be present on removal",type1Identities.remove(idScope.getId())); } else if (idScope.getId().getType().equals(type2)) { assertTrue("Element should be present on removal",type2Identities.remove(idScope.getId())); } } } } )
to
allEntitiesInSystemObservableImpl.getData().doOnNext(new Action1<EntityIdScope>(){ @Override public void call( final EntityIdScope entityIdScope){ assertNotNull(entityIdScope); assertNotNull(entityIdScope.getCollectionScope()); assertNotNull(entityIdScope.getId()); if (entityIdScope.getId().getType().equals(type1)) { assertTrue("Element should be present on removal",type1Identities.remove(entityIdScope.getId())); } else if (entityIdScope.getId().getType().equals(type2)) { assertTrue("Element should be present on removal",type2Identities.remove(entityIdScope.getId())); } } } )