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