java类java.io.StringBufferInputStream的实例源码

public static boolean check(String str) throws IOException {
    BufferedReader br = new BufferedReader(new InputStreamReader(new StringBufferInputStream(str)));
    ByteBuffer buffer = ByteBuffer.allocate(1024);
    String line = null;
    String lastLine = null;

    byte[] lastLineBytes;
    while ((line = br.readLine()) != null) {
        lastLine = line;
        lastLineBytes = line.getBytes();
        tryAllocate(buffer, lastLineBytes.length);
        buffer.put(lastLineBytes);
    }

    lastLineBytes = lastLine.getBytes();
    int equalsNum = 0;

    for (int src = lastLineBytes.length - 1; src >= lastLineBytes.length - 2; --src) {
        if (lastLineBytes[src] == 61) {
            ++equalsNum;
        }
    }

    byte[] var10 = buffer.toString().getBytes();

    for (int i = 0; i < var10.length - equalsNum; ++i) {
        char c = (char) var10[i];
        if ((c < 97 || c > 122) && (c < 65 || c > 90) && (c < 48 || c > 57) && c != 43 && c != 47) {
            return false;
        }
    }

    if ((var10.length - equalsNum) % 4 != 0) {
        return false;
    } else {
        return true;
    }
}

public static void main(String[] args) throws Exception {
    String s = "_123456789_123456789_123456789_123456789"; // s.length() > 33
    try (StringBufferInputStream sbis = new StringBufferInputStream(s)) {
        int len1 = 33;
        byte[] buf1 = new byte[len1];
        if (sbis.read(buf1, 0, len1) != len1)
            throw new Exception("Expected to read " + len1 + " bytes");

        int len2 = Integer.MAX_VALUE - 32;
        byte[] buf2 = new byte[len2];
        int expLen2 = s.length() - len1;
        if (sbis.read(buf2, 0, len2) != expLen2)
            throw new Exception("Expected to read " + expLen2 + " bytes");
    }
}

@DataProvider(name = "testAdvancedParameters")
private Object[][] testAdvancedParameters() throws SQLException {

    byte[] bytes = new byte[10];
    Ref aRef = new SerialRef(new StubRef("INTEGER", query));
    Array aArray = new SerialArray(new StubArray("INTEGER", new Object[1]));
    Blob aBlob = new SerialBlob(new StubBlob());
    Clob aClob = new SerialClob(new StubClob());
    Reader rdr = new StringReader(query);
    InputStream is = new StringBufferInputStream(query);;
    brs = new StubBaseRowSet();
    brs.setBytes(1, bytes);
    brs.setAsciiStream(2, is, query.length());
    brs.setRef(3, aRef);
    brs.setArray(4, aArray);
    brs.setBlob(5, aBlob);
    brs.setClob(6, aClob);
    brs.setBinaryStream(7, is, query.length());
    brs.setUnicodeStream(8, is, query.length());
    brs.setCharacterStream(9, rdr, query.length());

    return new Object[][]{
        {1, bytes},
        {2, is},
        {3, aRef},
        {4, aArray},
        {5, aBlob},
        {6, aClob},
        {7, is},
        {8, is},
        {9, rdr}
    };
}

public static void main(String[] args) throws Exception {
    String s = "_123456789_123456789_123456789_123456789"; // s.length() > 33
    try (StringBufferInputStream sbis = new StringBufferInputStream(s)) {
        int len1 = 33;
        byte[] buf1 = new byte[len1];
        if (sbis.read(buf1, 0, len1) != len1)
            throw new Exception("Expected to read " + len1 + " bytes");

        int len2 = Integer.MAX_VALUE - 32;
        byte[] buf2 = new byte[len2];
        int expLen2 = s.length() - len1;
        if (sbis.read(buf2, 0, len2) != expLen2)
            throw new Exception("Expected to read " + expLen2 + " bytes");
    }
}

@DataProvider(name = "testAdvancedParameters")
private Object[][] testAdvancedParameters() throws SQLException {

    byte[] bytes = new byte[10];
    Ref aRef = new SerialRef(new StubRef("INTEGER", query));
    Array aArray = new SerialArray(new StubArray("INTEGER", new Object[1]));
    Blob aBlob = new SerialBlob(new StubBlob());
    Clob aClob = new SerialClob(new StubClob());
    Reader rdr = new StringReader(query);
    InputStream is = new StringBufferInputStream(query);;
    brs = new StubBaseRowSet();
    brs.setBytes(1, bytes);
    brs.setAsciiStream(2, is, query.length());
    brs.setRef(3, aRef);
    brs.setArray(4, aArray);
    brs.setBlob(5, aBlob);
    brs.setClob(6, aClob);
    brs.setBinaryStream(7, is, query.length());
    brs.setUnicodeStream(8, is, query.length());
    brs.setCharacterStream(9, rdr, query.length());

    return new Object[][]{
        {1, bytes},
        {2, is},
        {3, aRef},
        {4, aArray},
        {5, aBlob},
        {6, aClob},
        {7, is},
        {8, is},
        {9, rdr}
    };
}

public static X509Certificate loadCertificate(String s)
        throws IOException, CertificateException {

    try (StringBufferInputStream is = new StringBufferInputStream(s)) {
        return (X509Certificate) CertificateFactory.getInstance("X509")
                .generateCertificate(is);
    }
}

@DataProvider(name = "testAdvancedParameters")
private Object[][] testAdvancedParameters() throws SQLException {

    byte[] bytes = new byte[10];
    Ref aRef = new SerialRef(new StubRef("INTEGER", query));
    Array aArray = new SerialArray(new StubArray("INTEGER", new Object[1]));
    Blob aBlob = new SerialBlob(new StubBlob());
    Clob aClob = new SerialClob(new StubClob());
    Reader rdr = new StringReader(query);
    InputStream is = new StringBufferInputStream(query);;
    brs = new StubBaseRowSet();
    brs.setBytes(1, bytes);
    brs.setAsciiStream(2, is, query.length());
    brs.setRef(3, aRef);
    brs.setArray(4, aArray);
    brs.setBlob(5, aBlob);
    brs.setClob(6, aClob);
    brs.setBinaryStream(7, is, query.length());
    brs.setUnicodeStream(8, is, query.length());
    brs.setCharacterStream(9, rdr, query.length());

    return new Object[][]{
        {1, bytes},
        {2, is},
        {3, aRef},
        {4, aArray},
        {5, aBlob},
        {6, aClob},
        {7, is},
        {8, is},
        {9, rdr}
    };
}

void runTest(String xmlString) {
    Bug6573786ErrorHandler handler = new Bug6573786ErrorHandler();
    try {
        InputStream is = new StringBufferInputStream(xmlString);
        SAXParser parser = SAXParserFactory.newInstance().newSAXParser();
        parser.parse(is, handler);
    } catch (Exception e) {
        if (handler.fail) {
            Assert.fail("The value of standalone attribute should be merged into the error message.");
        }
    }

}

@Test
public void WhenPutInFlowIntThanGetItFromFlow() throws IOException {
    AddTwoNum obj = new AddTwoNum();
    System.setIn(new StringBufferInputStream("1"));
    int result = obj.mainFlow(new InputStreamReader(System.in));
    int message = 1;
    Assert.assertThat(result,is(message));
}

/**
 * Tests whether initialLocation() gets called correctly when settings up
 * a SimScenario
 *
 * @throws Exception
 */
@Test
public void testInitialLocation()
throws Exception {
    // TODO: If more test cases are added that use Settings, they might
    // be run in parallel and break.

    // Setup the settings
    Settings.initFromStream(
            new StringBufferInputStream(INITIAL_LOC_TEST_SETTINGS));
    final DTNSimUI ui = new DTNSimUI() {
        @Override
        protected void runSim() {
            super.done();
        }
    };

    // Set the delegate for MovementListenerTestReport
    MovementListenerTestReport.setDelegate(new MovementReport());

    // Start the DTNSimUI, this will create SimScenario instance with all
    // the nodes and reports based on the configuration.
    ui.start();

    assertEquals("initialLocation() called incorrect number of time.",
            INITIAL_LOC_TEST_NODE_COUNT, INITIAL_LOC_CALL_COUNT);
}