com.github.davidmoten.rx2.flowable

Class Serialized

java.lang.Object

com.github.davidmoten.rx2.flowable.Serialized

public final class Serialized
extends Object

Utility class for writing Flowable streams to ObjectOutputStreams and reading Flowable streams of indeterminate size from ObjectInputStreams.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Serialized.KryoBuilder

Method Summary

Modifier and Type	Method and Description
static Serialized.KryoBuilder	kryo()
static Serialized.KryoBuilder	kryo(com.esotericsoftware.kryo.Kryo kryo)
static <T extends Serializable> io.reactivex.Flowable<T>	read(File file) Returns the deserialized objects from the given File as a Flowable stream.
static <T extends Serializable> io.reactivex.Flowable<T>	read(File file, int bufferSize) Returns the deserialized objects from the given File as a Flowable stream.
static <T extends Serializable> io.reactivex.Flowable<T>	read(ObjectInputStream ois) Returns the deserialized objects from the given InputStream as a Flowable stream.
static <T extends Serializable> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, File file) Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.
static <T extends Serializable> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, File file, boolean append) Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.
static <T extends Serializable> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, File file, boolean append, int bufferSize) Writes the source stream to the given file in given append mode and using the given buffer size.
static <T extends Serializable> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, ObjectOutputStream oos) Returns a duplicate of the input stream but with the side effect that emissions from the source are written to the ObjectOutputStream.

Methods inherited from class java.lang.Object

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

Method Detail

read

public static <T extends Serializable> io.reactivex.Flowable<T> read(ObjectInputStream ois)

Returns the deserialized objects from the given InputStream as a Flowable stream.

Type Parameters:

T - the generic type of the returned stream

Parameters:

ois - the ObjectInputStream

Returns:

the stream of deserialized objects from the InputStream as an Flowable.

read

public static <T extends Serializable> io.reactivex.Flowable<T> read(File file,
                                                                     int bufferSize)

Returns the deserialized objects from the given File as a Flowable stream. Uses buffer of size bufferSize buffer reads from the File.

Type Parameters:

T - the generic type of the deserialized objects returned in the stream

Parameters:

file - the input file

bufferSize - the buffer size for reading bytes from the file.

Returns:

the stream of deserialized objects from the InputStream as a Flowable.

read

public static <T extends Serializable> io.reactivex.Flowable<T> read(File file)

Returns the deserialized objects from the given File as a Flowable stream. A buffer size of 8192 bytes is used by default.

Type Parameters:

T - the generic type of the deserialized objects returned in the stream

Parameters:

file - the input file containing serialized java objects

Returns:

the stream of deserialized objects from the InputStream as an Flowable.

write

public static <T extends Serializable> io.reactivex.Flowable<T> write(io.reactivex.Flowable<T> source,
                                                                      ObjectOutputStream oos)

Returns a duplicate of the input stream but with the side effect that emissions from the source are written to the ObjectOutputStream.

Type Parameters:

T - the generic type of the objects being serialized

Parameters:

source - the source of objects to write

oos - the output stream to write to

Returns:

re-emits the input stream

write

public static <T extends Serializable> io.reactivex.Flowable<T> write(io.reactivex.Flowable<T> source,
                                                                      File file,
                                                                      boolean append,
                                                                      int bufferSize)

Writes the source stream to the given file in given append mode and using the given buffer size.

Type Parameters:

T - the generic type of the input stream

Parameters:

source - flowable stream to write

file - file to write to

append - if true writes are appended to file otherwise overwrite the file

bufferSize - the buffer size in bytes to use.

Returns:

re-emits the input stream

write

public static <T extends Serializable> io.reactivex.Flowable<T> write(io.reactivex.Flowable<T> source,
                                                                      File file,
                                                                      boolean append)

Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.

Type Parameters:

T - the generic type of the input stream

Parameters:

source - flowable stream to write

file - file to write to

append - if true writes are appended to file otherwise overwrite the file

Returns:

re-emits the input stream

write

public static <T extends Serializable> io.reactivex.Flowable<T> write(io.reactivex.Flowable<T> source,
                                                                      File file)

Writes the source stream to the given file in given append mode and using the a buffer size of 8192 bytes.

Type Parameters:

T - the generic type of the input stream

Parameters:

source - flowable stream to write

file - file to write to

Returns:

re-emits the input stream

kryo

public static Serialized.KryoBuilder kryo()

kryo

public static Serialized.KryoBuilder kryo(com.esotericsoftware.kryo.Kryo kryo)