@Test
public void testCoerce() throws Exception {

  Pipe p = Pump.prime()
      .discard("offset")
      .each(new RegexFilter("^[0-9]+$", false), "line")
      .coerce("line", long.class)
      .toPipe();
  CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), p).complete();
  assertEquals(Arrays.asList("115200000", "0", "115200000"), getOutputStrings());
}