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

  runProcess(buildProcessor(), new CompleteNotifier<Integer>() {
    @Override
    public void complete(
        final ByteArray id,
        final Integer value,
        final NeighborList<Integer> list) throws IOException, InterruptedException {
      final Iterator<Entry<ByteArray, Integer>> it = list.iterator();
      final List<Integer> expectedResultSet = new ArrayList<>(expectedResults.get(value));
      assertNotNull(expectedResultSet);
      while (it.hasNext()) {
        final Integer result = it.next().getValue();
        assertTrue("" + value + " with " + result, expectedResultSet.remove(result));
      }
      assertTrue(expectedResultSet.isEmpty());
    }
  });
}