@Test
public void testDecode() throws Exception {

  MpegTsDecoder mpegTsDecoder = mock(MpegTsDecoder.class);
  MTSPacketToPESPacketDecoder decoder = new MTSPacketToPESPacketDecoder(mpegTsDecoder);
  MTSPacket mtsPacket = mock(MTSPacket.class);
  EmbeddedChannel channel = new EmbeddedChannel(decoder);
  channel.writeInbound(mtsPacket);
  NettyUtility.read(channel);
  verify(mpegTsDecoder).read(eq(mtsPacket), anyObject());
}