下面列出了怎么用org.apache.commons.io.input.ClosedInputStream的API类实例代码及写法,或者点击链接到github查看源代码。
/**
* 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));
}
/**
* 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));
}
@Override
public InputSource resolveEntity(String publicId, String systemId) {
return new InputSource(ClosedInputStream.CLOSED_INPUT_STREAM);
}
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
return ClosedInputStream.CLOSED_INPUT_STREAM;
}
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
return ClosedInputStream.CLOSED_INPUT_STREAM;
}
@Override
public InputSource resolveEntity(String publicId, String systemId) {
return new InputSource(ClosedInputStream.CLOSED_INPUT_STREAM);
}
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI,
String namespace) {
return ClosedInputStream.CLOSED_INPUT_STREAM;
}
@Override
public InputStream resolveEntity(String publicId, String systemId, String baseURI, String namespace) {
return ClosedInputStream.CLOSED_INPUT_STREAM;
}