Pipe { public boolean isStarted() { return source.isStarted() && destination.isStarted(); }  String getName(); Mutation<?> getLastMutation(); void start(); void stop(); void removeSourceListener(); boolean isStarted(); void checkpoint();  }
@Test public void testIsStarted() throws Exception { when(source.isStarted()).thenReturn(true); when(destination.isStarted()).thenReturn(false); assertFalse(pipe.isStarted()); when(source.isStarted()).thenReturn(false); when(destination.isStarted()).thenReturn(true); assertFalse(pipe.isStarted()); when(source.isStarted()).thenReturn(true); when(destination.isStarted()).thenReturn(true); assertTrue(pipe.isStarted()); }