@Test(timeout = TIMEOUT) public void testSingleByteRead() throws IOException { InputStream is = new MergeBytesInputStream(new ByteArrayInputStream(TEST_DATA)); assertEquals(0x44, is.read()); assertEquals(MergeBytesInputStream.BEGIN_FRAME, is.read()); assertEquals(0x55, is.read()); assertEquals(0x85, is.read()); assertEquals(0x00, is.read()); assertEquals(0x80, is.read()); is.close(); }
@Override public int read(byte[] b) throws IOException { return read(b, 0, b.length); }
MergeBytesInputStream extends java.io.FilterInputStream { @Override public int read(byte[] b) throws IOException { return read(b, 0, b.length); } }
MergeBytesInputStream extends java.io.FilterInputStream { @Override public int read(byte[] b) throws IOException { return read(b, 0, b.length); } MergeBytesInputStream(java.io.InputStream inputStream);  MergeBytesInputStream(java.io.InputStream inputStream, int beginFrame, int endFrame, int escape, Merger merger); }
MergeBytesInputStream extends java.io.FilterInputStream { @Override public int read(byte[] b) throws IOException { return read(b, 0, b.length); } MergeBytesInputStream(java.io.InputStream inputStream);  MergeBytesInputStream(java.io.InputStream inputStream, int beginFrame, int endFrame, int escape, Merger merger); @Override int read(byte[] b); @Override int read(byte[] b, int off, int len); @Override int read(); }
MergeBytesInputStream extends java.io.FilterInputStream { @Override public int read(byte[] b) throws IOException { return read(b, 0, b.length); } MergeBytesInputStream(java.io.InputStream inputStream);  MergeBytesInputStream(java.io.InputStream inputStream, int beginFrame, int endFrame, int escape, Merger merger); @Override int read(byte[] b); @Override int read(byte[] b, int off, int len); @Override int read(); static final int BEGIN_FRAME; static final int END_FRAME; static final int END_OF_FILE; }