@Test
public void testBuild() throws ExecutionException, InterruptedException {

    AsyncModelBuilder mdlBuilder = new ThreadedModelBuilder(10);
    Model<Integer, Future<Integer>> infMdl = mdlBuilder.build(
        ModelBuilderTestUtil.getReader(),
        ModelBuilderTestUtil.getParser()
    );
    for (int i = 0; i < 100; i++)
        assertEquals(Integer.valueOf(i), infMdl.predict(i).get());
}