public final class IO extends Object
Modifier and Type | Class and Description |
---|---|
static class |
IO.FileContext
A read access to the source file
|
Modifier and Type | Method and Description |
---|---|
static org.reactivestreams.Publisher<Buffer> |
read(ReadableByteChannel channel)
Transform a
ReadableByteChannel into a Publisher of Buffer with a max chunk size of
Buffer.SMALL_BUFFER_SIZE . |
static org.reactivestreams.Publisher<Buffer> |
read(ReadableByteChannel channel,
int chunkSize)
|
static org.reactivestreams.Publisher<Buffer> |
readFile(Path path)
|
static org.reactivestreams.Publisher<Buffer> |
readFile(Path path,
int chunkSize)
|
static org.reactivestreams.Publisher<Buffer> |
readFile(String path)
|
static org.reactivestreams.Publisher<Buffer> |
readFile(String path,
int chunkSize)
|
public static org.reactivestreams.Publisher<Buffer> read(ReadableByteChannel channel)
ReadableByteChannel
into a Publisher
of Buffer
with a max chunk size of
Buffer.SMALL_BUFFER_SIZE
.
Complete when channel read is negative. The read sequence is unique per subscriber.channel
- The Readable Channel to publishpublic static org.reactivestreams.Publisher<Buffer> read(ReadableByteChannel channel, int chunkSize)
ReadableByteChannel
into a Publisher
of Buffer
with a max chunk size of
chunkSize
.
Complete when channel read is negative. The read sequence is unique per subscriber.channel
- The Readable Channel to publishpublic static org.reactivestreams.Publisher<Buffer> readFile(Path path)
Buffer
from file specified by the Path
argument with a max chunk size of
Buffer.SMALL_BUFFER_SIZE
.
Complete when channel read is negative. The read sequence is unique per subscriber.path
- the Path
locating the file to readpublic static org.reactivestreams.Publisher<Buffer> readFile(Path path, int chunkSize)
Buffer
from file specified by the Path
argument with a max chunkSize
Complete when channel read is negative. The read sequence is unique per subscriber.path
- the Path
locating the file to readpublic static org.reactivestreams.Publisher<Buffer> readFile(String path)
Buffer
from file specified by the Path
argument with a max chunk size of
Buffer.SMALL_BUFFER_SIZE
.
Complete when channel read is negative. The read sequence is unique per subscriber.path
- the absolute String path to the read filepublic static org.reactivestreams.Publisher<Buffer> readFile(String path, int chunkSize)
Buffer
from file specified by the Path
argument with a max chunkSize
Complete when channel read is negative. The read sequence is unique per subscriber.path
- the absolute String path to the read fileCopyright © 2016. All rights reserved.