Java 类org.apache.commons.io.input.ReaderInputStream 实例源码

项目：FHIR-Server 文件：TagsClientTest.java

@Test
public void testGetAllTagsPatient() throws Exception {

    TagList tagList = new TagList();
    tagList.add(new Tag("CCC", "AAA", "BBB"));
    String ser = ctx.newXmlParser().encodeTagListToString(tagList);

    ArgumentCaptor<HttpUriRequest> capt = ArgumentCaptor.forClass(HttpUriRequest.class);
    when(httpClient.execute(capt.capture())).thenReturn(httpResponse);
    when(httpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, "OK"));
    when(httpResponse.getEntity().getContentType()).thenReturn(new BasicHeader("content-type", Constants.CT_FHIR_XML + "; charset=UTF-8"));
    when(httpResponse.getEntity().getContent()).thenReturn(new ReaderInputStream(new StringReader(ser), Charset.forName("UTF-8")));

    IClient client = ctx.newRestfulClient(IClient.class, "http://foo");
    TagList response = client.getAllTagsPatient();
    assertEquals(tagList, response);

    assertEquals(HttpGet.class, capt.getValue().getClass());
    HttpGet get = (HttpGet) capt.getValue();
    assertEquals("http://foo/Patient/_tags", get.getURI().toString());
}

项目：streamflyer 文件：ByteStreamTest.java

private void assertInputConversion_viaCharsetName(String charsetName, boolean conversionErrorsExpected)
        throws Exception {

    byte[] originalBytes = createBytes();

    {
        // byte array as byte stream
        InputStream originalByteStream = new ByteArrayInputStream(originalBytes);
        // byte stream as character stream
        Reader originalReader = new InputStreamReader(originalByteStream, charsetName);
        // modifying reader (we don't modify here)
        Reader modifyingReader = new ModifyingReader(originalReader, new RegexModifier("a", 0, "a"));
        // character stream as byte stream
        InputStream modifyingByteStream = new ReaderInputStream(modifyingReader, charsetName);
        // byte stream as byte array
        byte[] modifiedBytes = IOUtils.toByteArray(modifyingByteStream);

        assertBytes(originalBytes, modifiedBytes, conversionErrorsExpected);
    }
}

项目：streamflyer 文件：ProcessEndOfStreamTest.java

/**
 * @param flush
 * @return Returns true if the actual output is equals to the expected
 *         output.
 * @throws Exception
 */
private boolean rewriteContent(boolean flush, String domainPrefix) throws Exception {
    String contentPart = StringUtils.repeat("text", 2);
    String oldUrl = domainPrefix + "something";
    String expectedNewUrl = domainPrefix + "anything";
    String oldHtml = "<html><body>" + contentPart + oldUrl + contentPart + "</body></html>";
    String expectedNewHtml = "<html><body>" + contentPart + expectedNewUrl + contentPart + "</body></html>";
    String encoding = "UTF-8";

    ByteArrayOutputStream os = new ByteArrayOutputStream();
    long written = rewriteContent(new ReaderInputStream(new StringReader(oldHtml)), os, encoding, flush);
    System.out.println("written: " + written);
    System.out.println("oldHtml.length(): " + oldHtml.length());
    System.out.println("expectedNewHtml.length(): " + expectedNewHtml.length());
    System.out.println("expectedNewHtml: \n" + expectedNewHtml);
    os.flush();
    String newHtml = new String(os.toByteArray(), encoding);
    System.out.println(newHtml);
    return expectedNewHtml.equals(newHtml);
}

项目：appformer 文件：GuvnorM2Repository.java

private static InputStream getInputStreamFromJar(final InputStream jarInputStream,
                                                 final String prefix,
                                                 final String suffix) throws IOException {
    ZipInputStream zis = new ZipInputStream(jarInputStream);
    ZipEntry entry;

    while ((entry = zis.getNextEntry()) != null) {
        final String entryName = entry.getName();
        if (entryName.startsWith(prefix) && entryName.endsWith(suffix)) {
            return new ReaderInputStream( new InputStreamReader( zis,
                                                                 "UTF-8"));
        }
    }

    throw new FileNotFoundException("Could not find '" + prefix + "/*/" + suffix + "' in the jar.");
}

项目：FHIR-Server 文件：TagsClientTest.java

@Test
public void testAddTagsPatientVersion() throws Exception {

    ArgumentCaptor<HttpUriRequest> capt = ArgumentCaptor.forClass(HttpUriRequest.class);
    when(httpClient.execute(capt.capture())).thenReturn(httpResponse);
    when(httpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, "OK"));
    when(httpResponse.getEntity().getContentType().getElements()).thenReturn(new HeaderElement[0]);
    when(httpResponse.getEntity().getContent()).thenReturn(new ReaderInputStream(new StringReader(""), Charset.forName("UTF-8")));

    TagList tagList = new TagList();
    tagList.add(new Tag("CCC", "AAA", "BBB"));

    IClient client = ctx.newRestfulClient(IClient.class, "http://foo");
    client.addTags(new IdDt("111"), new IdDt("222"),tagList);

    assertEquals(HttpPost.class, capt.getValue().getClass());
    HttpPost post = (HttpPost) capt.getValue();
    assertEquals("http://foo/Patient/111/_history/222/_tags", post.getURI().toString());

    String ser = IOUtils.toString(post.getEntity().getContent());
    TagList actualTagList = ctx.newXmlParser().parseTagList(ser);
    assertEquals(tagList, actualTagList);
}

项目：FHIR-Server 文件：GenericClientTest.java

@Test
public void testTransaction() throws Exception {
    String bundleStr = IOUtils.toString(getClass().getResourceAsStream("/bundle.json"));
    Bundle bundle = ourCtx.newJsonParser().parseBundle(bundleStr);

    ArgumentCaptor<HttpUriRequest> capt = ArgumentCaptor.forClass(HttpUriRequest.class);
    when(myHttpClient.execute(capt.capture())).thenReturn(myHttpResponse);
    when(myHttpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, "OK"));
    when(myHttpResponse.getEntity().getContentType()).thenReturn(new BasicHeader("content-type", Constants.CT_FHIR_JSON + "; charset=UTF-8"));
    when(myHttpResponse.getEntity().getContent()).thenReturn(new ReaderInputStream(new StringReader(bundleStr), Charset.forName("UTF-8")));

    IGenericClient client = ourCtx.newRestfulGenericClient("http://example.com/fhir");

    //@formatter:off
    Bundle response = client.transaction()
            .withBundle(bundle)
            .execute();
    //@formatter:on

    assertEquals("http://example.com/fhir", capt.getValue().getURI().toString());
    assertEquals(bundle.getEntries().get(0).getId(), response.getEntries().get(0).getId());
    assertEquals(EncodingEnum.XML.getBundleContentType() + Constants.HEADER_SUFFIX_CT_UTF_8, capt.getAllValues().get(0).getFirstHeader(Constants.HEADER_CONTENT_TYPE).getValue());

}

项目：FHIR-Server 文件：TagsClientTest.java

@Test
public void testDeleteTagsPatientVersion() throws Exception {

    ArgumentCaptor<HttpUriRequest> capt = ArgumentCaptor.forClass(HttpUriRequest.class);
    when(httpClient.execute(capt.capture())).thenReturn(httpResponse);
    when(httpResponse.getStatusLine()).thenReturn(new BasicStatusLine(new ProtocolVersion("HTTP", 1, 1), 200, "OK"));
    when(httpResponse.getEntity().getContentType().getElements()).thenReturn(new HeaderElement[0]);
    when(httpResponse.getEntity().getContent()).thenReturn(new ReaderInputStream(new StringReader(""), Charset.forName("UTF-8")));

    TagList tagList = new TagList();
    tagList.add(new Tag("CCC", "AAA", "BBB"));

    IClient client = ctx.newRestfulClient(IClient.class, "http://foo");
    client.deleteTags(new IdDt("111"), new IdDt("222"),tagList);

    assertEquals(HttpPost.class, capt.getValue().getClass());
    HttpPost post = (HttpPost) capt.getValue();
    assertEquals("http://foo/Patient/111/_history/222/_tags/_delete", post.getURI().toString());

    String ser = IOUtils.toString(post.getEntity().getContent());
    TagList actualTagList = ctx.newXmlParser().parseTagList(ser);
    assertEquals(tagList, actualTagList);
}