Pipe { public void checkpoint() { source.checkpoint(getLastMutation()); }  String getName(); Mutation<?> getLastMutation(); void start(); void stop(); void removeSourceListener(); boolean isStarted(); void checkpoint();  }
@Test public void testCheckpoint() throws Exception { pipe.checkpoint(); verify(source, times(1)).checkpoint(lastMutation); }