deleteIndexEdge

IndexServiceImpl.java

        final Observable<IndexOperationMessage> batches =  Observable.just( edge ).map(
            observableEdge -> generateScopeFromSource( edge ) ).flatMap( indexEdge -> {

            final ApplicationEntityIndex ei = entityIndexFactory.createApplicationEntityIndex( applicationScope );

            //TODO: make method to keep looping through elasticsearch until there are no more indexs to batchup
            CandidateResults crs = ei.search( indexEdge, SearchTypes.fromTypes( edge.getType() ), "select *", 10, 0 );

            final EntityIndexBatch batch = ei.createBatch();

            logger.debug( "deleting edge {} to batch for scope {}", indexEdge, applicationScope );

            //TODO: extract this into its own function.
            Iterator itr = crs.iterator();
            while( itr.hasNext() ) {
                CandidateResult cr = ( CandidateResult ) itr.next();
                batch.deindex( indexEdge, cr.getId(), cr.getVersion() );
            }

            return batch.execute();
        } );

        return ObservableTimer.time( batches, addTimer  );