com.github.davidmoten.rx

Class Serialized.KryoBuilder

java.lang.Object

com.github.davidmoten.rx.Serialized.KryoBuilder

Enclosing class:

Serialized

public static class Serialized.KryoBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
<T> rx.Observable<T>	read(Class<T> cls, File file)
<T> rx.Observable<T>	read(Class<T> cls, File file, int bufferSize)
<T> rx.Observable<T>	read(Class<T> cls, com.esotericsoftware.kryo.io.Input input, int bufferSize)
<T> rx.Observable<T>	write(rx.Observable<T> source, File file)
<T> rx.Observable<T>	write(rx.Observable<T> source, File file, boolean append)
<T> rx.Observable<T>	write(rx.Observable<T> source, File file, boolean append, int bufferSize)

Methods inherited from class java.lang.Object

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

Method Detail

write

public <T> rx.Observable<T> write(rx.Observable<T> source,
                                  File file)

write

public <T> rx.Observable<T> write(rx.Observable<T> source,
                                  File file,
                                  boolean append)

write

public <T> rx.Observable<T> write(rx.Observable<T> source,
                                  File file,
                                  boolean append,
                                  int bufferSize)

read

public <T> rx.Observable<T> read(Class<T> cls,
                                 File file)

read

public <T> rx.Observable<T> read(Class<T> cls,
                                 File file,
                                 int bufferSize)

read

public <T> rx.Observable<T> read(Class<T> cls,
                                 com.esotericsoftware.kryo.io.Input input,
                                 int bufferSize)