A B C D E F G H I J K L M N O P Q R S T U V W X Z

M

many() - Static method in class reactor.core.publisher.Sinks

Help building Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber.

many() - Method in interface reactor.core.publisher.Sinks.RootSpec

Help building Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber.

manyWithUpstream() - Method in interface reactor.core.publisher.Sinks.RootSpec

Help building Sinks.ManyWithUpstream sinks that can also be subscribed to an upstream Publisher.

map(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux

Transform the items emitted by this Flux by applying a synchronous function to each item.

map(Function<? super T, ? extends R>) - Method in class reactor.core.publisher.Mono

Transform the item emitted by this Mono by applying a synchronous function to it.

map(Function<? super T, ? extends U>) - Method in class reactor.core.publisher.ParallelFlux

Maps the source values on each 'rail' to another value.

mapNotNull(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux

Transform the items emitted by this Flux by applying a synchronous function to each item, which may produce null values.

mapNotNull(Function<? super T, ? extends R>) - Method in class reactor.core.publisher.Mono

Transform the item emitted by this Mono by applying a synchronous function to it, which is allowed to produce a null value.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple2

Map the left-hand part (T1) of this Tuple2 into a different value and type, keeping the right-hand part (T2).

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple3

Map the 1st part (T1) of this Tuple3 into a different value and type, keeping the other parts.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple4

Map the 1st part (T1) of this Tuple4 into a different value and type, keeping the other parts.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple5

Map the 1st part (T1) of this Tuple5 into a different value and type, keeping the other parts.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple6

Map the 1st part (T1) of this Tuple6 into a different value and type, keeping the other parts.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple7

Map the 1st part (T1) of this Tuple7 into a different value and type, keeping the other parts.

mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple8

Map the 1st part (T1) of this Tuple8 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple2

Map the right-hand part (T2) of this Tuple2 into a different value and type, keeping the left-hand part (T1).

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple3

Map the 2nd part (T2) of this Tuple3 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple4

Map the 2nd part (T2) of this Tuple4 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple5

Map the 2nd part (T2) of this Tuple5 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple6

Map the 2nd part (T2) of this Tuple6 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple7

Map the 2nd part (T2) of this Tuple7 into a different value and type, keeping the other parts.

mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple8

Map the 2nd part (T2) of this Tuple8 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple3

Map the 3rd part (T3) of this Tuple3 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple4

Map the 3rd part (T3) of this Tuple4 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple5

Map the 3rd part (T3) of this Tuple5 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple6

Map the 3rd part (T3) of this Tuple6 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple7

Map the 3rd part (T3) of this Tuple7 into a different value and type, keeping the other parts.

mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple8

Map the 3rd part (T3) of this Tuple8 into a different value and type, keeping the other parts.

mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple4

Map the 4th part (T4) of this Tuple4 into a different value and type, keeping the other parts.

mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple5

Map the 4th part (T4) of this Tuple5 into a different value and type, keeping the other parts.

mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple6

Map the 4th part (T4) of this Tuple6 into a different value and type, keeping the other parts.

mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple7

Map the 4th part (T4) of this Tuple7 into a different value and type, keeping the other parts.

mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple8

Map the 4th part (T4) of this Tuple8 into a different value and type, keeping the other parts.

mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple5

Map the 5th part (T5) of this Tuple5 into a different value and type, keeping the other parts.

mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple6

Map the 5th part (T5) of this Tuple6 into a different value and type, keeping the other parts.

mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple7

Map the 5th part (T5) of this Tuple7 into a different value and type, keeping the other parts.

mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple8

Map the 5th part (T5) of this Tuple8 into a different value and type, keeping the other parts.

mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple6

Map the 6th part (T6) of this Tuple6 into a different value and type, keeping the other parts.

mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple7

Map the 6th part (T6) of this Tuple7 into a different value and type, keeping the other parts.

mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple8

Map the 6th part (T6) of this Tuple8 into a different value and type, keeping the other parts.

mapT7(Function<T7, R>) - Method in class reactor.util.function.Tuple7

Map the 7th part (T7) of this Tuple7 into a different value and type, keeping the other parts.

mapT7(Function<T7, R>) - Method in class reactor.util.function.Tuple8

Map the 7th part (T7) of this Tuple8 into a different value and type, keeping the other parts.

mapT8(Function<T8, R>) - Method in class reactor.util.function.Tuple8

Map the 8th part (t8) of this Tuple8 into a different value and type, keeping the other parts.

matches(Predicate<Context>) - Method in interface reactor.test.StepVerifier.ContextExpectations

Check that the propagated Context matches a given Predicate.

matches(Predicate<Context>, String) - Method in interface reactor.test.StepVerifier.ContextExpectations

Check that the propagated Context matches a given Predicate that is given a description.

matches(CONTAINER) - Method in interface reactor.test.ValueFormatters.Extractor

An additional test to perform on a matching container to further decide to convert it or not.

matches(TypeDescription) - Method in class reactor.tools.agent.ReactorDebugByteBuddyPlugin

materialize() - Method in class reactor.core.publisher.Flux

Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.

materialize() - Method in class reactor.core.publisher.Mono

Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.

max(long) - Static method in class reactor.util.retry.Retry

A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts.

maxAttempts - Variable in class reactor.util.retry.RetryBackoffSpec

The configured maximum for retry attempts.

maxAttempts(long) - Method in class reactor.util.retry.RetryBackoffSpec

Set the maximum number of retry attempts allowed.

maxAttempts - Variable in class reactor.util.retry.RetrySpec

The configured maximum for retry attempts.

maxAttempts(long) - Method in class reactor.util.retry.RetrySpec

Set the maximum number of retry attempts allowed.

maxBackoff - Variable in class reactor.util.retry.RetryBackoffSpec

The configured maximum backoff Duration.

maxBackoff(Duration) - Method in class reactor.util.retry.RetryBackoffSpec

Set a hard maximum Duration for exponential backoffs.

maxInARow(long) - Static method in class reactor.util.retry.Retry

A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors.

merge(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.

merge(Publisher<? extends Publisher<? extends T>>, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.

merge(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.

merge(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences contained in an Iterable into an interleaved merged sequence.

merge(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.

merge(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.

mergeComparing(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by their natural order).

mergeComparing(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).

mergeComparing(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).

mergeComparingDelayError(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).

mergeComparingWith(Publisher<? extends T>, Comparator<? super T>) - Method in class reactor.core.publisher.Flux

Merge data from this Flux and a Publisher into a reordered merge sequence, by picking the smallest value from each sequence as defined by a provided Comparator.

mergeDelayError(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.

mergeOrdered(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Deprecated.

Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.

mergeOrdered(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Deprecated.

Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.

mergeOrdered(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Deprecated.

Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.

mergeOrderedWith(Publisher<? extends T>, Comparator<? super T>) - Method in class reactor.core.publisher.Flux

Deprecated.

Use Flux.mergeComparingWith(Publisher, Comparator) instead (with the caveat that it defaults to NOT delaying errors, unlike this operator). To be removed in 3.6.0 at the earliest.

mergePriority(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by their natural order) as they arrive.

mergePriority(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.

mergePriority(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.

mergePriorityDelayError(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux

Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.

mergeSequential(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.

mergeSequential(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.

mergeSequential(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.

mergeSequential(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.

mergeSequential(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.

mergeSequential(Iterable<? extends Publisher<? extends I>>, int, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.

mergeSequentialDelayError(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.

mergeSequentialDelayError(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.

mergeSequentialDelayError(Iterable<? extends Publisher<? extends I>>, int, int) - Static method in class reactor.core.publisher.Flux

Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.

mergeWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux

Merge data from this Flux and a Publisher into an interleaved merged sequence.

mergeWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Mono

Merge emissions of this Mono with the provided Publisher.

metrics(MeterRegistry) - Static method in class reactor.core.observability.micrometer.Micrometer

A SignalListener factory that will ultimately produce Micrometer metrics to the provided MeterRegistry (and using the registry's configured Clock in case additional timings are needed).

metrics() - Method in class reactor.core.publisher.Flux

Deprecated.

Prefer using the Flux.tap(SignalListenerFactory) with the SignalListenerFactory provided by the new reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.

metrics() - Method in class reactor.core.publisher.Mono

Deprecated.

Prefer using the Mono.tap(SignalListenerFactory) with the SignalListenerFactory provided by the new reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.

Metrics - Class in reactor.util

Deprecated.

prefer using the new reactor-core-micrometer module Micrometer entrypoint. To be removed in 3.6.0 at the earliest.

Metrics() - Constructor for class reactor.util.Metrics

Deprecated.

Metrics.MicrometerConfiguration - Class in reactor.util

Deprecated.

Prefer using the reactor-core-micrometer module and configuring it using the Micrometer entrypoint.

Micrometer - Class in reactor.core.observability.micrometer

Micrometer() - Constructor for class reactor.core.observability.micrometer.Micrometer

MicrometerConfiguration() - Constructor for class reactor.util.Metrics.MicrometerConfiguration

Deprecated.

MicrometerMeterListenerDocumentation - Enum in reactor.core.observability.micrometer

Meters and tags used by Micrometer.metrics(MeterRegistry).

MicrometerMeterListenerDocumentation.CommonTags - Enum in reactor.core.observability.micrometer

Tags that are common to all PublisherMeters.

MicrometerMeterListenerDocumentation.TerminationTags - Enum in reactor.core.observability.micrometer

Additional tags for PublisherMeters#FLOW_DURATION that reflects the termination of the sequence.

MicrometerObservationListenerDocumentation - Enum in reactor.core.observability.micrometer

Documentation of Micrometer.observation(ObservationRegistry) tags and of the anonymous variant of the observation (no Flux.name(String)).

MicrometerObservationListenerDocumentation.ObservationTags - Enum in reactor.core.observability.micrometer

Tags used in the Observation set up by Micrometer.observation() tap listeners.

minBackoff - Variable in class reactor.util.retry.RetryBackoffSpec

The configured minimum backoff Duration.

minBackoff(Duration) - Method in class reactor.util.retry.RetryBackoffSpec

Set the minimum Duration for the first backoff.

modifyErrorFilter(Function<Predicate<Throwable>, Predicate<? super Throwable>>) - Method in class reactor.util.retry.RetryBackoffSpec

Allows to augment a previously set Predicate with a new condition to allow retries of some exception or not.

modifyErrorFilter(Function<Predicate<Throwable>, Predicate<? super Throwable>>) - Method in class reactor.util.retry.RetrySpec

Allows to augment a previously set Predicate with a new condition to allow retries of some exception or not.

Mono<T> - Class in reactor.core.publisher

A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).

Mono() - Constructor for class reactor.core.publisher.Mono

mono() - Method in class reactor.test.publisher.PublisherProbe.DefaultPublisherProbe

mono() - Method in interface reactor.test.publisher.PublisherProbe

Return a Mono version of the probe.

mono() - Method in class reactor.test.publisher.TestPublisher

Convenience method to wrap this TestPublisher to a Mono.

MonoOperator<I,O> - Class in reactor.core.publisher

A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.

MonoOperator(Mono<? extends I>) - Constructor for class reactor.core.publisher.MonoOperator

Build a MonoOperator wrapper around the passed parent Publisher

MonoProcessor<O> - Class in reactor.core.publisher

Deprecated.

Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives

MonoProcessor() - Constructor for class reactor.core.publisher.MonoProcessor

Deprecated.

MonoSink<T> - Interface in reactor.core.publisher

Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).

MonoSubscriber(CoreSubscriber<? super O>) - Constructor for class reactor.core.publisher.Operators.MonoSubscriber

multicast() - Method in interface reactor.core.publisher.Sinks.ManySpec

Help building Sinks.Many that will broadcast signals to multiple Subscriber

multicastOnBackpressureBuffer() - Method in interface reactor.core.publisher.Sinks.ManyWithUpstreamUnsafeSpec

A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.

multicastOnBackpressureBuffer(int, boolean) - Method in interface reactor.core.publisher.Sinks.ManyWithUpstreamUnsafeSpec

A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.

multiple(Throwable...) - Static method in class reactor.core.Exceptions

Create a composite exception that wraps the given Throwable(s), as suppressed exceptions.

multiple(Iterable<Throwable>) - Static method in class reactor.core.Exceptions

Create a composite exception that wraps the given Throwable(s), as suppressed exceptions.

multiplyCap(long, long) - Static method in class reactor.core.publisher.Operators

Cap a multiplication to Long.MAX_VALUE

A B C D E F G H I J K L M N O P Q R S T U V W X Z