public class WriteObservable<T> extends Observable<T> {

	private final Observable<T> observable;

	private int flushCount;


	private WriteObservable(Observable<T> o) {
		super(null);
		this.observable = o;
	}


	static <S> WriteObservable<S> wrap(Observable<S> o) {
		return new WriteObservable<S>(o);
	}


	public WriteObservable<T> withFlushCount(int count) {
		this.flushCount = count;
		return this;
	}

	public Publisher<T> toPublisher() {
		return WritePublisher.adapt(RxReactiveStreams.toPublisher(this.observable)).withFlushCount(this.flushCount);
	}

}