@Test(timeout = DEFAULT_CONVERSION_TIMEOUT)
public void testInputStreamSourceToInputStreamConsumerExecute() throws Exception {
File source = validFile(true);
InputStream inputStream = spy(new FileInputStream(source));
IInputStreamSource inputStreamSource = mock(IInputStreamSource.class);
when(inputStreamSource.getInputStream()).thenReturn(inputStream);
OutputStream outputStream = mock(OutputStream.class);
IInputStreamConsumer inputStreamConsumer = mock(IInputStreamConsumer.class);
doAnswer(new CloseStreamAnswer()).when(inputStreamConsumer).onComplete(any(InputStream.class));