@Test
public void testReplace() throws Exception {

  Pipe p = Pump.prime()
      .replace("offset", "line")
      .toPipe();
  CascadingHelper.get().getFlowConnector().connect(Tests.getInTap(), Tests.getOutTap(), p).complete();
  assertEquals(Arrays.asList("0", "10", "12", "22"), getOutputStrings());
}