@Test(expected = CatalogTransformerException.class)
public void testInputStreamReadError() throws Exception {

  MpegTsInputTransformer t =
      new MpegTsInputTransformer(
          inputTransformer,
          metacardTypes,
          stanag4609Processor,
          klvHandlerFactory,
          defaultKlvHandler,
          stanagParserFactory,
          klvProcessor,
          DISTANCE_TOLERANCE);
  InputStream inputStream = mock(InputStream.class);
  when(inputStream.read(any())).thenThrow(new IOException());
  t.transform(inputStream);
}