Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement