@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());
}