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

G

generate(Consumer<SynchronousSink<T>>) - Static method in class reactor.core.publisher.Flux

Programmatically create a Flux by generating signals one-by-one via a consumer callback.

generate(Callable<S>, BiFunction<S, SynchronousSink<T>, S>) - Static method in class reactor.core.publisher.Flux

Programmatically create a Flux by generating signals one-by-one via a consumer callback and some state.

generate(Callable<S>, BiFunction<S, SynchronousSink<T>, S>, Consumer<? super S>) - Static method in class reactor.core.publisher.Flux

Programmatically create a Flux by generating signals one-by-one via a consumer callback and some state, with a final cleanup callback.

generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.Retry

Generates the companion publisher responsible for reacting to incoming Retry.RetrySignal emissions, effectively deciding when to retry.

generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.RetryBackoffSpec

generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.RetrySpec

get() - Method in interface reactor.core.publisher.Signal

Retrieves the item associated with this (onNext) signal.

get() - Method in interface reactor.core.publisher.Timed

Get the value wrapped by this Timed.

get() - Static method in class reactor.test.scheduler.VirtualTimeScheduler

The current VirtualTimeScheduler assigned in Schedulers

get(int) - Static method in class reactor.util.concurrent.Queues

get(Object) - Method in interface reactor.util.context.ContextView

Resolve a value given a key that exists within the Context, or throw a NoSuchElementException if the key is not present.

get(Class<T>) - Method in interface reactor.util.context.ContextView

Resolve a value given a type key within the Context.

get(int) - Method in class reactor.util.function.Tuple2

Get the object at the given index.

get(int) - Method in class reactor.util.function.Tuple3

get(int) - Method in class reactor.util.function.Tuple4

get(int) - Method in class reactor.util.function.Tuple5

get(int) - Method in class reactor.util.function.Tuple6

get(int) - Method in class reactor.util.function.Tuple7

get(int) - Method in class reactor.util.function.Tuple8

get(boolean) - Method in interface reactor.util.Logger.ChoiceOfMessageSupplier

Provide two possible versions of a message String, depending on the level of detail desired.

getBufferSize() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

getBufferSize() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

Return the processor buffer capacity if any or Integer.MAX_VALUE

getBufferSize() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

getContextView() - Method in interface reactor.core.publisher.Signal

Return the readonly ContextView that is accessible by the time this Signal was emitted.

getErrContent() - Method in class reactor.test.util.TestLogger

getError() - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

getError() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

getError() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

Current error if any, default to null

getError() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

Return the produced Throwable error if any or null

getError() - Method in class reactor.core.publisher.ReplayProcessor

Deprecated.

getError() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

getExtractors() - Method in class reactor.test.StepVerifierOptions

Get the list of value extractors added to the options, including default ones at the end (unless they've been individually replaced).

getFusionMode() - Method in class reactor.core.observability.DefaultSignalListener

Return the fusion mode negotiated with the source: Fuseable.SYNC and Fuseable.ASYNC) as relevant if some fusion was negotiated.

getFusionMode() - Method in interface reactor.test.subscriber.TestSubscriber

Return an int code that represents the negotiated fusion mode for this TestSubscriber.

getInitialContext() - Method in class reactor.test.StepVerifierOptions

getInitialRequest() - Method in class reactor.test.StepVerifierOptions

getLogger(String) - Static method in class reactor.util.Loggers

Get a Logger.

getLogger(Class<?>) - Static method in class reactor.util.Loggers

Get a Logger, backed by SLF4J if present on the classpath or falling back to java.util.logging.Logger.

getName() - Method in class reactor.test.util.TestLogger

getName() - Method in interface reactor.util.Logger

Return the name of this Logger instance.

getOrDefault(Object, T) - Method in interface reactor.util.context.ContextView

Resolve a value given a key within the Context.

getOrEmpty(Object) - Method in interface reactor.util.context.ContextView

Resolve a value given a key within the Context.

getOrSet() - Static method in class reactor.test.scheduler.VirtualTimeScheduler

Assign a newly created VirtualTimeScheduler to all Schedulers.Factory factories ONLY if no VirtualTimeScheduler is currently set.

getOrSet(boolean) - Static method in class reactor.test.scheduler.VirtualTimeScheduler

Assign a newly created VirtualTimeScheduler to all Schedulers.Factory factories ONLY if no VirtualTimeScheduler is currently set.

getOrSet(VirtualTimeScheduler) - Static method in class reactor.test.scheduler.VirtualTimeScheduler

Assign an externally created VirtualTimeScheduler to the relevant Schedulers.Factory factories, depending on how it was created (see VirtualTimeScheduler.create() and VirtualTimeScheduler.create()).

getOutContent() - Method in class reactor.test.util.TestLogger

getPending() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

Return the number of parked elements in the emitter backlog.

getPrefetch() - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

getPrefetch() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

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

The prefetch configuration of the Flux

getPrefetch() - Method in class reactor.core.publisher.ParallelFlux

The prefetch configuration of the component

getPrefetch() - Method in class reactor.core.publisher.ReplayProcessor

Deprecated.

getPrefetch() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

getProtocolErrors() - Method in interface reactor.test.subscriber.TestSubscriber

Return a List of Signal which represent detected protocol error from the source Publisher, that is to say signals that were emitted to this TestSubscriber in violation of the Reactive Streams specification.

getReason() - Method in exception reactor.core.publisher.Sinks.EmissionException

Get the failure Sinks.EmitResult code that is represented by this exception.

getReceivedOnNext() - Method in interface reactor.test.subscriber.TestSubscriber

Return the List of all elements that have correctly been emitted to the TestSubscriber (onNext signals) so far.

getReceivedOnNextAfterCancellation() - Method in interface reactor.test.subscriber.TestSubscriber

Return the List of elements that have been emitted to the TestSubscriber (onNext signals) so far, after a TestSubscriber.cancel() was triggered.

getRegistry() - Static method in class reactor.util.Metrics.MicrometerConfiguration

Deprecated.

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

getScenarioName() - Method in class reactor.test.StepVerifierOptions

getScheduledTaskCount() - Method in class reactor.test.scheduler.VirtualTimeScheduler

Get the number of scheduled tasks.

getSubscription() - Method in interface reactor.core.publisher.Signal

Read the subscription associated with this (onSubscribe) signal.

getT1() - Method in class reactor.util.function.Tuple2

Type-safe way to get the first object of this Tuples.

getT2() - Method in class reactor.util.function.Tuple2

Type-safe way to get the second object of this Tuples.

getT3() - Method in class reactor.util.function.Tuple3

Type-safe way to get the third object of this Tuples.

getT4() - Method in class reactor.util.function.Tuple4

Type-safe way to get the fourth object of this Tuples.

getT5() - Method in class reactor.util.function.Tuple5

Type-safe way to get the fifth object of this Tuples.

getT6() - Method in class reactor.util.function.Tuple6

Type-safe way to get the sixth object of this Tuples.

getT7() - Method in class reactor.util.function.Tuple7

Type-safe way to get the seventh object of this Tuples.

getT8() - Method in class reactor.util.function.Tuple8

Type-safe way to get the eighth object of this Tuples.

getTargetClass() - Method in interface reactor.test.ValueFormatters.Extractor

Return the targeted container Class.

getTerminalSignal() - Method in interface reactor.test.subscriber.TestSubscriber

Return the terminal Signal if this TestSubscriber TestSubscriber.isTerminated(), or null otherwise.

getThrowable() - Method in interface reactor.core.publisher.Signal

Read the error associated with this (onError) signal.

getType() - Method in interface reactor.core.publisher.Signal

Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE

getValueFormatter() - Method in class reactor.test.StepVerifierOptions

Get the custom object formatter to use when producing messages.

getVirtualTimeSchedulerSupplier() - Method in class reactor.test.StepVerifierOptions

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

Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.

groupBy(Function<? super T, ? extends K>, int) - Method in class reactor.core.publisher.Flux

Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.

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

Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.

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

Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.

GroupedFlux<K,V> - Class in reactor.core.publisher

Represents a sequence of events which has an associated key.

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

groupJoin(Publisher<? extends TRight>, Function<? super T, ? extends Publisher<TLeftEnd>>, Function<? super TRight, ? extends Publisher<TRightEnd>>, BiFunction<? super T, ? super Flux<TRight>, ? extends R>) - Method in class reactor.core.publisher.Flux

Map values from two Publishers into time windows and emit combination of values in case their windows overlap.

groups() - Method in class reactor.core.publisher.ParallelFlux

Exposes the 'rails' as individual GroupedFlux instances, keyed by the rail index (zero based).

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