reactor.io

Class IO

java.lang.Object

reactor.io.IO

public final class IO
extends Object

A factory for Reactive basic IO operations such as File read/write, Byte read and Codec decoding.

Since:

2.0.4

Author:

Stephane Maldini

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IO.FileContext A read access to the source file

Method Summary

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) Transform a ReadableByteChannel into a Publisher of Buffer with a max chunk size of chunkSize.
static org.reactivestreams.Publisher<Buffer>	readFile(Path path) Read bytes as Buffer from file specified by the Path argument with a max chunk size of Buffer.SMALL_BUFFER_SIZE.
static org.reactivestreams.Publisher<Buffer>	readFile(Path path, int chunkSize) Read bytes as Buffer from file specified by the Path argument with a max chunkSize Complete when channel read is negative.
static org.reactivestreams.Publisher<Buffer>	readFile(String path) Read bytes as Buffer from file specified by the Path argument with a max chunk size of Buffer.SMALL_BUFFER_SIZE.
static org.reactivestreams.Publisher<Buffer>	readFile(String path, int chunkSize) Read bytes as Buffer from file specified by the Path argument with a max chunkSize Complete when channel read is negative.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

read

public 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. Complete when channel read is negative. The read sequence is unique per subscriber.

Parameters:

channel - The Readable Channel to publish

Returns:

a Publisher of Buffer values

read

public static org.reactivestreams.Publisher<Buffer> read(ReadableByteChannel channel,
                                                         int chunkSize)

Transform a 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.

Parameters:

channel - The Readable Channel to publish

Returns:

a Publisher of Buffer values

readFile

public static org.reactivestreams.Publisher<Buffer> readFile(Path path)

Read bytes as 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.

Parameters:

path - the Path locating the file to read

Returns:

a Publisher of Buffer values read from file sequentially

readFile

public static org.reactivestreams.Publisher<Buffer> readFile(Path path,
                                                             int chunkSize)

Read bytes as 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.

Parameters:

path - the Path locating the file to read

Returns:

a Publisher of Buffer values read from file sequentially

readFile

public static org.reactivestreams.Publisher<Buffer> readFile(String path)

Read bytes as 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.

Parameters:

path - the absolute String path to the read file

Returns:

a Publisher of Buffer values read from file sequentially

readFile

public static org.reactivestreams.Publisher<Buffer> readFile(String path,
                                                             int chunkSize)

Read bytes as 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.

Parameters:

path - the absolute String path to the read file

Returns:

a Publisher of Buffer values read from file sequentially