public final class OnSubscribeSumInt extends java.lang.Object implements io.reactivex.ObservableOnSubscribe<java.lang.Integer>
OnSubscribeSumInt(io.reactivex.Observable<java.lang.Integer> source, boolean zeroDefault)
void
subscribe(io.reactivex.ObservableEmitter<java.lang.Integer> e)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public OnSubscribeSumInt(io.reactivex.Observable<java.lang.Integer> source, boolean zeroDefault)
public void subscribe(io.reactivex.ObservableEmitter<java.lang.Integer> e) throws java.lang.Exception
subscribe
io.reactivex.ObservableOnSubscribe<java.lang.Integer>
java.lang.Exception