com.github.davidmoten.rx

Class Serialized

java.lang.Object

com.github.davidmoten.rx.Serialized

public final class Serialized
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Serialized.KryoBuilder

Constructor Summary

Constructors

Constructor and Description
Serialized()

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> rx.Observable<T>	read(File file) Returns the deserialized objects from the given File as an Observable stream.
static <T extends Serializable> rx.Observable<T>	read(File file, int bufferSize) Returns the deserialized objects from the given File as an Observable stream.
static <T extends Serializable> rx.Observable<T>	read(ObjectInputStream ois) Returns the deserialized objects from the given InputStream as an Observable stream.
static <T extends Serializable> rx.Observable<T>	write(rx.Observable<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> rx.Observable<T>	write(rx.Observable<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> rx.Observable<T>	write(rx.Observable<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> rx.Observable<T>	write(rx.Observable<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

Constructor Detail

Serialized

public Serialized()

Method Detail

read

public static <T extends Serializable> rx.Observable<T> read(ObjectInputStream ois)

Returns the deserialized objects from the given InputStream as an Observable 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 Observable.

read

public static <T extends Serializable> rx.Observable<T> read(File file,
                                                             int bufferSize)

Returns the deserialized objects from the given File as an Observable 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 an Observable.

read

public static <T extends Serializable> rx.Observable<T> read(File file)

Returns the deserialized objects from the given File as an Observable 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 Observable.

write

public static <T extends Serializable> rx.Observable<T> write(rx.Observable<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> rx.Observable<T> write(rx.Observable<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 - observable 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> rx.Observable<T> write(rx.Observable<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 - observable 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> rx.Observable<T> write(rx.Observable<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 - observable 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)