@Test
public void testDiscard() throws IOException {

  Pipe p = Pump.prime()
      .discard("offset")
      .toPipe();
  CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), p).complete();
  assertEquals(Arrays.asList("115200000", "0", "115200000", "asdf"), getOutputStrings());
}