com.github.davidmoten.rx2.flowable

Class CloseableFlowableWithReset<T>

java.lang.Object

com.github.davidmoten.rx2.flowable.CloseableFlowableWithReset<T>

public final class CloseableFlowableWithReset<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
CloseableFlowableWithReset(io.reactivex.Flowable<T> flowable, Runnable closeAction, Runnable resetAction)

Method Summary

Modifier and Type	Method and Description
void	close()
io.reactivex.Flowable<T>	flowable()
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

CloseableFlowableWithReset

public CloseableFlowableWithReset(io.reactivex.Flowable<T> flowable,
                                  Runnable closeAction,
                                  Runnable resetAction)

Method Detail

flowable

public io.reactivex.Flowable<T> flowable()

reset

public void reset()

close

public void close()