InputStreamRewinder(InputStream is, ArrayPool byteArrayPool) { bufferedStream = new RecyclableBufferedInputStream(is, byteArrayPool); bufferedStream.mark(MARK_LIMIT); }
@Before public void setUp() throws Exception { wrapped = mock(RecyclableBufferedInputStream.class); is = new ExceptionCatchingInputStream(); is.setInputStream(wrapped); }
@Synthetic InputStreamRewinder(InputStream is, ArrayPool byteArrayPool) { bufferedStream = new RecyclableBufferedInputStream(is, byteArrayPool); bufferedStream.mark(MARK_LIMIT); }
public InputStream build(InputStream is, byte[] buffer) { return new RecyclableBufferedInputStream(is, buffer); }