类org.apache.commons.io.input.ClosedInputStream源码实例Demo

下面列出了怎么用org.apache.commons.io.input.ClosedInputStream的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: aion-germany   文件: ByteArrayOutputStream.java
/**
 * Gets the current contents of this byte stream as a Input Stream. The
 * returned stream is backed by buffers of <code>this</code> stream,
 * avoiding memory allocation and copy, thus saving space and time.<br>
 * 
 * @return the current contents of this output stream.
 * @see java.io.ByteArrayOutputStream#toByteArray()
 * @see #reset()
 * @since 2.0
 */
private InputStream toBufferedInputStream() {
    int remaining = count;
    if (remaining == 0) {
        return new ClosedInputStream();
    }
    List<ByteArrayInputStream> list = new ArrayList<ByteArrayInputStream>(buffers.size());
    for (byte[] buf : buffers) {
        int c = Math.min(buf.length, remaining);
        list.add(new ByteArrayInputStream(buf, 0, c));
        remaining -= c;
        if (remaining == 0) {
            break;
        }
    }
    return new SequenceInputStream(Collections.enumeration(list));
}
 
源代码2 项目: lams   文件: ByteArrayOutputStream.java
/**
 * Gets the current contents of this byte stream as a Input Stream. The
 * returned stream is backed by buffers of <code>this</code> stream,
 * avoiding memory allocation and copy, thus saving space and time.<br>
 *
 * @return the current contents of this output stream.
 * @see java.io.ByteArrayOutputStream#toByteArray()
 * @see #reset()
 * @since 2.5
 */
public synchronized InputStream toInputStream() {
    int remaining = count;
    if (remaining == 0) {
        return new ClosedInputStream();
    }
    final List<ByteArrayInputStream> list = new ArrayList<ByteArrayInputStream>(buffers.size());
    for (final byte[] buf : buffers) {
        final int c = Math.min(buf.length, remaining);
        list.add(new ByteArrayInputStream(buf, 0, c));
        remaining -= c;
        if (remaining == 0) {
            break;
        }
    }
    reuseBuffers = false;
    return new SequenceInputStream(Collections.enumeration(list));
}
 
源代码3 项目: lucene-solr   文件: EmptyEntityResolver.java
@Override
public InputSource resolveEntity(String publicId, String systemId) {
  return new InputSource(ClosedInputStream.CLOSED_INPUT_STREAM);
}
 
源代码4 项目: lucene-solr   文件: EmptyEntityResolver.java
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
  return ClosedInputStream.CLOSED_INPUT_STREAM;
}
 
源代码5 项目: lucene-solr   文件: XmlOffsetCorrector.java
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
  return ClosedInputStream.CLOSED_INPUT_STREAM;
}
 
源代码6 项目: hadoop-solr   文件: EmptyEntityResolver.java
@Override
public InputSource resolveEntity(String publicId, String systemId) {
  return new InputSource(ClosedInputStream.CLOSED_INPUT_STREAM);
}
 
源代码7 项目: hadoop-solr   文件: EmptyEntityResolver.java
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI,
    String namespace) {
  return ClosedInputStream.CLOSED_INPUT_STREAM;
}
 
源代码8 项目: SolrTextTagger   文件: XmlOffsetCorrector.java
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
  return ClosedInputStream.CLOSED_INPUT_STREAM;
}
 
 类所在包
 类方法
 同包方法