com.github.davidmoten.rx2.flowable

Class Serialized.KryoBuilder

java.lang.Object

com.github.davidmoten.rx2.flowable.Serialized.KryoBuilder

Enclosing class:

Serialized

public static class Serialized.KryoBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
<T> io.reactivex.Flowable<T>	read(Class<T> cls, File file)
<T> io.reactivex.Flowable<T>	read(Class<T> cls, File file, int bufferSize)
<T> io.reactivex.Flowable<T>	read(Class<T> cls, com.esotericsoftware.kryo.io.Input input)
<T> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, File file)
<T> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<T> source, File file, boolean append)
<T> io.reactivex.Flowable<T>	write(io.reactivex.Flowable<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> io.reactivex.Flowable<T> write(io.reactivex.Flowable<T> source,
                                          File file)

write

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

write

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

read

public <T> io.reactivex.Flowable<T> read(Class<T> cls,
                                         File file)

read

public <T> io.reactivex.Flowable<T> read(Class<T> cls,
                                         File file,
                                         int bufferSize)

read

public <T> io.reactivex.Flowable<T> read(Class<T> cls,
                                         com.esotericsoftware.kryo.io.Input input)