Java 类com.fasterxml.jackson.core.io.MergedStream 实例源码

public void testSimple() throws Exception
{
    BufferRecycler rec = new BufferRecycler();
    IOContext ctxt = new IOContext(rec, null, false);
    // bit complicated; must use recyclable buffer...
    byte[] first = ctxt.allocReadIOBuffer();
    System.arraycopy("ABCDE".getBytes("UTF-8"), 0, first, 99, 5);
    byte[] second = "FGHIJ".getBytes("UTF-8");

    assertNull(ctxt.getSourceReference());
    assertFalse(ctxt.isResourceManaged());
    ctxt.setEncoding(JsonEncoding.UTF8);
    MergedStream ms = new MergedStream(ctxt, new ByteArrayInputStream(second),
                                       first, 99, 99+5);
    // Ok, first, should have 5 bytes from first buffer:
    assertEquals(5, ms.available());
    // not supported when there's buffered stuff...
    assertFalse(ms.markSupported());
    // so this won't work, but shouldn't throw exception
    ms.mark(1);
    assertEquals((byte) 'A', ms.read());
    assertEquals(3, ms.skip(3));
    byte[] buffer = new byte[5];
    /* Ok, now, code is allowed to return anywhere between 1 and 3,
     * but we now it will return 1...
     */
    assertEquals(1, ms.read(buffer, 1, 3));
    assertEquals((byte) 'E', buffer[1]);
    // So let's read bit more
    assertEquals(3, ms.read(buffer, 0, 3));
    assertEquals((byte) 'F', buffer[0]);
    assertEquals((byte) 'G', buffer[1]);
    assertEquals((byte) 'H', buffer[2]);
    assertEquals(2, ms.available());
    // And then skip the reset
    assertEquals(2, ms.skip(200));

    ms.close();
}

public InputStream getDataStream()
{
  if (this._originalStream == null)
    return new ByteArrayInputStream(this._bufferedData, this._bufferedStart, this._bufferedLength);
  return new MergedStream(null, this._originalStream, this._bufferedData, this._bufferedStart, this._bufferedLength);
}

public InputStream getDataStream()
{
  if (this._originalStream == null)
    return new ByteArrayInputStream(this._bufferedData, this._bufferedStart, this._bufferedLength);
  return new MergedStream(null, this._originalStream, this._bufferedData, this._bufferedStart, this._bufferedLength);
}

/**
 * Method to use for accessing input for which format detection has been done.
 * This <b>must</b> be used instead of using stream passed to detector
 * unless given stream itself can do buffering.
 * Stream will return all content that was read during matching process, as well
 * as remaining contents of the underlying stream.
 */
public InputStream getDataStream() {
    if (_originalStream == null) {
        return new ByteArrayInputStream(_bufferedData, _bufferedStart, _bufferedLength);
    }
    return new MergedStream(null, _originalStream, _bufferedData, _bufferedStart, _bufferedLength);
}

/**
 * Method to use for accessing input for which format detection has been done.
 * This <b>must</b> be used instead of using stream passed to detector
 * unless given stream itself can do buffering.
 * Stream will return all content that was read during matching process, as well
 * as remaining contents of the underlying stream.
 */
public InputStream getDataStream() {
    if (_originalStream == null) {
        return new ByteArrayInputStream(_bufferedData, _bufferedStart, _bufferedLength);
    }
    return new MergedStream(null, _originalStream, _bufferedData, _bufferedStart, _bufferedLength);
}

/**
 * Method to use for accessing input for which format detection has been done.
 * This <b>must</b> be used instead of using stream passed to detector
 * unless given stream itself can do buffering.
 * Stream will return all content that was read during matching process, as well
 * as remaining contents of the underlying stream.
 */
public InputStream getDataStream() {
    if (_originalStream == null) {
        return new ByteArrayInputStream(_bufferedData, _bufferedStart, _bufferedLength);
    }
    return new MergedStream(null, _originalStream, _bufferedData, _bufferedStart, _bufferedLength);
}