@Test
public void testRemoveOp() throws IOException, InterruptedException {

  final NNProcessor<Integer, Integer> processor = buildProcessor();
  runProcess(processor, new CompleteNotifier<Integer>() {
    @Override
    public void complete(
        final ByteArray id,
        final Integer value,
        final NeighborList<Integer> list) throws IOException, InterruptedException {
      processor.remove(id);
    }
  });
}