reactor.math

Class MonoSumBigDecimal<T>

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.math.MonoSumBigDecimal<T>

Type Parameters:

T - the input value type

All Implemented Interfaces:

org.reactivestreams.Publisher<BigDecimal>, reactor.core.CorePublisher<BigDecimal>, reactor.core.Fuseable, reactor.core.Scannable

public class MonoSumBigDecimal<T>
extends reactor.core.publisher.Mono<O>
implements reactor.core.Fuseable

Computes the sun of source numbers and returns the result as BigDecimal

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Fuseable

reactor.core.Fuseable.ConditionalSubscriber<T>, reactor.core.Fuseable.QueueSubscription<T>, reactor.core.Fuseable.ScalarCallable<T>, reactor.core.Fuseable.SynchronousSubscription<T>

Nested classes/interfaces inherited from interface reactor.core.Scannable

reactor.core.Scannable.Attr<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected reactor.core.publisher.Flux<? extends I>	source

Fields inherited from interface reactor.core.Fuseable

ANY, ASYNC, NONE, SYNC, THREAD_BARRIER

Fields inherited from interface reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

Modifier and Type	Method and Description
Object	scanUnsafe(reactor.core.Scannable.Attr key)
void	subscribe(reactor.core.CoreSubscriber<? super BigDecimal> actual)

Methods inherited from class reactor.core.publisher.Mono

and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextCapture, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, mapNotNull, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, share, single, singleOptional, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWhen, zipWhen, zipWith, zipWith

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.Fuseable

fusionModeName, fusionModeName

Methods inherited from interface reactor.core.Scannable

actuals, from, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated

Field Detail

source

protected final reactor.core.publisher.Flux<? extends I> source

Method Detail

subscribe

public void subscribe(reactor.core.CoreSubscriber<? super BigDecimal> actual)

Specified by:

subscribe in interface reactor.core.CorePublisher<BigDecimal>

Specified by:

subscribe in class reactor.core.publisher.Mono<BigDecimal>

scanUnsafe

@Nullable
public Object scanUnsafe(reactor.core.Scannable.Attr key)

Specified by:

scanUnsafe in interface reactor.core.Scannable