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