public static class ReadAheadInputStream.Builder extends AbstractStreamBuilder<ReadAheadInputStream,ReadAheadInputStream.Builder>
ReadAheadInputStream
instance.
For example:
ReadAheadInputStream s = ReadAheadInputStream.builder()
.setPath(path)
.setExecutorService(Executors.newSingleThreadExecutor(ReadAheadInputStream::newThread))
.get();
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ExecutorService |
executorService |
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
ReadAheadInputStream |
get()
Constructs a new instance.
|
ReadAheadInputStream.Builder |
setExecutorService(java.util.concurrent.ExecutorService executorService)
Sets the executor service for the read-ahead thread.
|
getBufferSize, getBufferSizeDefault, getCharSequence, getCharset, getCharsetDefault, getInputStream, getOpenOptions, getOutputStream, getPath, getWriter, setBufferSize, setBufferSize, setBufferSizeChecker, setBufferSizeDefault, setBufferSizeMax, setCharset, setCharset, setCharsetDefault, setOpenOptions
checkOrigin, getOrigin, hasOrigin, newByteArrayOrigin, newCharSequenceOrigin, newFileOrigin, newFileOrigin, newInputStreamOrigin, newOutputStreamOrigin, newPathOrigin, newPathOrigin, newReaderOrigin, newURIOrigin, newWriterOrigin, setByteArray, setCharSequence, setFile, setFile, setInputStream, setOrigin, setOutputStream, setPath, setPath, setReader, setURI, setWriter
asThis
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
asSupplier
public ReadAheadInputStream get() throws java.io.IOException
This builder use the aspects InputStream, OpenOption[], buffer size, ExecutorService.
You must provide an origin that can be converted to an InputStream by this builder, otherwise, this call will throw an
UnsupportedOperationException
.
java.lang.UnsupportedOperationException
- if the origin cannot provide an InputStream.java.io.IOException
- if an I/O error occurs.AbstractStreamBuilder.getInputStream()
public ReadAheadInputStream.Builder setExecutorService(java.util.concurrent.ExecutorService executorService)
executorService
- the executor service for the read-ahead thread.