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

G

generate(Consumer<SynchronousSink<T>>) - 类 中的静态方法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>) - 类 中的静态方法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>) - 类 中的静态方法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.

generate() - 类 中的静态方法reactor.doc.DocUtil

generateCompanion(Flux<Retry.RetrySignal>) - 类 中的方法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>) - 类 中的方法reactor.util.retry.RetryBackoffSpec

generateCompanion(Flux<Retry.RetrySignal>) - 类 中的方法reactor.util.retry.RetrySpec

generateEmpty() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generateError() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generateJust() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generateJustBackpressured() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generateRange() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generateRangeBackpressured() - 类 中的方法reactor.core.publisher.FluxGenerateTest

GenerateSlowPathStressTest() - 类 的构造器reactor.core.publisher.FluxGenerateStressTest.GenerateSlowPathStressTest

generatorMultipleOnCompletes() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generatorMultipleOnErrors() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generatorMultipleOnNexts() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generatorNull() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generatorThrows() - 类 中的方法reactor.core.publisher.FluxGenerateTest

generatorThrowsFusion() - 类 中的方法reactor.core.publisher.FluxGenerateTest

get() - 接口 中的方法reactor.core.publisher.Signal

Retrieves the item associated with this (onNext) signal.

get() - 接口 中的方法reactor.core.publisher.Timed

Get the value wrapped by this Timed.

get() - 类 中的静态方法reactor.test.scheduler.VirtualTimeScheduler

The current VirtualTimeScheduler assigned in Schedulers

get(int) - 类 中的静态方法reactor.util.concurrent.Queues

get() - 类 中的方法reactor.util.context.Context1Test

get() - 类 中的方法reactor.util.context.Context2Test

get() - 类 中的方法reactor.util.context.Context3Test

get() - 类 中的方法reactor.util.context.Context4Test

get() - 类 中的方法reactor.util.context.Context5Test

get() - 类 中的方法reactor.util.context.ContextNTest

get(Object) - 接口 中的方法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>) - 接口 中的方法reactor.util.context.ContextView

Resolve a value given a type key within the Context.

get(int) - 类 中的方法reactor.util.function.Tuple2

Get the object at the given index.

get(int) - 类 中的方法reactor.util.function.Tuple3

get(int) - 类 中的方法reactor.util.function.Tuple4

get(int) - 类 中的方法reactor.util.function.Tuple5

get(int) - 类 中的方法reactor.util.function.Tuple6

get(int) - 类 中的方法reactor.util.function.Tuple7

get(int) - 类 中的方法reactor.util.function.Tuple8

get(boolean) - 接口 中的方法reactor.util.Logger.ChoiceOfMessageSupplier

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

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple2Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple3Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple4Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple5Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple6Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple7Test

getAllValuesCorrespondToArray() - 类 中的方法reactor.util.function.Tuple8Test

getBufferSize() - 类 中的方法reactor.core.publisher.EmitterProcessor

已过时。

getBufferSize() - 类 中的方法reactor.core.publisher.FluxProcessor

已过时。

Return the processor buffer capacity if any or Integer.MAX_VALUE

getBufferSize() - 类 中的方法reactor.core.publisher.UnicastProcessor

已过时。

getClasses(String) - 类 中的静态方法reactor.doc.ClassUtil

根据包名获取包下面所有的类名

getClassName() - 接口 中的方法java.lang.StackWalker.StackFrame

getConsoleLoggerShouldBeThreadSafe() - 类 中的方法reactor.util.ConsoleLoggerTest

Ensure console logger factory synchronizes logger acquisition properly.

getContextView() - 接口 中的方法reactor.core.publisher.Signal

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

getDisposableShouldReturnset() - 类 中的方法reactor.core.SwapDisposableTest

getErrContent() - 类 中的方法reactor.test.util.TestLogger

getError() - 类 中的方法reactor.core.publisher.DirectProcessor

已过时。

getError() - 类 中的方法reactor.core.publisher.EmitterProcessor

已过时。

getError() - 类 中的方法reactor.core.publisher.FluxProcessor

已过时。

Current error if any, default to null

getError() - 类 中的方法reactor.core.publisher.MonoProcessor

已过时。

Return the produced Throwable error if any or null

getError() - 类 中的方法reactor.core.publisher.ReplayProcessor

已过时。

getError() - 类 中的方法reactor.core.publisher.UnicastProcessor

已过时。

getExtractors() - 类 中的方法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() - 接口 中的方法reactor.test.subscriber.TestSubscriber

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

getInitialContext() - 类 中的方法reactor.test.StepVerifierOptions

getInitialRequest() - 类 中的方法reactor.test.StepVerifierOptions

getInstance() - 类 中的静态方法java.lang.StackWalker

getLogger(String) - 类 中的静态方法reactor.util.Loggers

Get a Logger.

getLogger(Class<?>) - 类 中的静态方法reactor.util.Loggers

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

getMethodName() - 接口 中的方法java.lang.StackWalker.StackFrame

getName() - 类 中的方法reactor.core.util.FastLogger

getName() - 类 中的方法reactor.test.util.TestLogger

getName() - 接口 中的方法reactor.util.Logger

Return the name of this Logger instance.

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple2Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple3Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple4Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple5Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple6Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple7Test

getNegativeIndex() - 类 中的方法reactor.util.function.Tuple8Test

getOnEachOperatorHooksIsUnmodifiable() - 类 中的方法reactor.core.publisher.HooksTest

getOnLastOperatorHooksIsUnmodifiable() - 类 中的方法reactor.core.publisher.HooksTest

getOnOperatorErrorHooksIsUnmodifiable() - 类 中的方法reactor.core.publisher.HooksTest

getOrDefault(Object, T) - 接口 中的方法reactor.util.context.ContextView

Resolve a value given a key within the Context.

getOrEmpty(Object) - 接口 中的方法reactor.util.context.ContextView

Resolve a value given a key within the Context.

getOrEmptyWhenMatch() - 类 中的方法reactor.util.context.ContextViewTest

getOrEmptyWhenNoMatch() - 类 中的方法reactor.util.context.ContextViewTest

getOrSet() - 类 中的静态方法reactor.test.scheduler.VirtualTimeScheduler

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

getOrSet(boolean) - 类 中的静态方法reactor.test.scheduler.VirtualTimeScheduler

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

getOrSet(VirtualTimeScheduler) - 类 中的静态方法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()).

getOrSetWithDefer() - 类 中的方法reactor.test.scheduler.VirtualTimeSchedulerTests

getOutContent() - 类 中的方法reactor.test.util.TestLogger

getPending() - 类 中的方法reactor.core.publisher.EmitterProcessor

已过时。

Return the number of parked elements in the emitter backlog.

getPrefetch() - 类 中的方法reactor.core.publisher.DirectProcessor

已过时。

getPrefetch() - 类 中的方法reactor.core.publisher.EmitterProcessor

已过时。

getPrefetch() - 类 中的方法reactor.core.publisher.Flux

The prefetch configuration of the Flux

getPrefetch() - 类 中的方法reactor.core.publisher.ParallelFlux

The prefetch configuration of the component

getPrefetch() - 类 中的方法reactor.core.publisher.ReplayProcessor

已过时。

getPrefetch() - 类 中的方法reactor.core.publisher.UnicastProcessor

已过时。

getProtocolErrors() - 接口 中的方法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() - 异常错误 中的方法reactor.core.publisher.Sinks.EmissionException

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

getReceivedOnNext() - 接口 中的方法reactor.test.subscriber.TestSubscriber

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

getReceivedOnNextAfterCancellation() - 接口 中的方法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() - 类 中的静态方法reactor.util.Metrics.MicrometerConfiguration

已过时。

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

getScenarioName() - 类 中的方法reactor.test.StepVerifierOptions

getScheduledTaskCount() - 类 中的方法reactor.test.scheduler.VirtualTimeScheduler

Get the number of scheduled tasks.

getSubscription() - 接口 中的方法reactor.core.publisher.Signal

Read the subscription associated with this (onSubscribe) signal.

getT1() - 类 中的方法reactor.util.function.Tuple2

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

getT2() - 类 中的方法reactor.util.function.Tuple2

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

getT3() - 类 中的方法reactor.util.function.Tuple3

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

getT4() - 类 中的方法reactor.util.function.Tuple4

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

getT5() - 类 中的方法reactor.util.function.Tuple5

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

getT6() - 类 中的方法reactor.util.function.Tuple6

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

getT7() - 类 中的方法reactor.util.function.Tuple7

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

getT8() - 类 中的方法reactor.util.function.Tuple8

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

getTargetClass() - 接口 中的方法reactor.test.ValueFormatters.Extractor

Return the targeted container Class.

getTerminalSignal() - 接口 中的方法reactor.test.subscriber.TestSubscriber

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

getThrowable() - 接口 中的方法reactor.core.publisher.Signal

Read the error associated with this (onError) signal.

getThrows() - 类 中的方法reactor.util.context.Context0Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple2Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple3Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple4Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple5Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple6Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple7Test

getTooLargeIndex() - 类 中的方法reactor.util.function.Tuple8Test

getType() - 接口 中的方法reactor.core.publisher.Signal

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

getUnknown() - 类 中的方法reactor.util.context.Context1Test

getUnknown() - 类 中的方法reactor.util.context.Context2Test

getUnknown() - 类 中的方法reactor.util.context.Context3Test

getUnknown() - 类 中的方法reactor.util.context.Context4Test

getUnknown() - 类 中的方法reactor.util.context.Context5Test

getUnknown() - 类 中的方法reactor.util.context.ContextNTest

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context0Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context1Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context2Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context3Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context4Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.Context5Test

getUnknownWithDefault() - 类 中的方法reactor.util.context.ContextNTest

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context0Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context1Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context2Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context3Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context4Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.Context5Test

getUnknownWithDefaultNull() - 类 中的方法reactor.util.context.ContextNTest

getValueFormatter() - 类 中的方法reactor.test.StepVerifierOptions

Get the custom object formatter to use when producing messages.

getVirtualTimeSchedulerSupplier() - 类 中的方法reactor.test.StepVerifierOptions

getWithClass() - 类 中的方法reactor.util.context.ContextViewTest

getWithClassKeyButNonMatchingInstance() - 类 中的方法reactor.util.context.ContextViewTest

getZone() - 类 中的方法reactor.test.MockUtils.VirtualClock

gh1194() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferTimeoutTest

gh1236_test() - 类 中的方法reactor.test.publisher.ColdTestPublisherTests

gh1666_bufferNine() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferTest

gh1666_bufferThree() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferTest

gh1978() - 类 中的方法reactor.core.publisher.FluxRetryWhenTest

gh1992() - 类 中的方法reactor.core.scheduler.BoundedElasticSchedulerTest

gh2196_discardHandlerHang() - 类 中的方法reactor.core.publisher.MonoRepeatWhenEmptyTest

gh507() - 类 中的方法reactor.core.publisher.FluxSubscribeOnTest

gh783() - 类 中的方法reactor.test.StepVerifierTests

gh783_deferredAdvanceTime() - 类 中的方法reactor.test.StepVerifierTests

gh783_firstSmallAdvance() - 类 中的方法reactor.test.StepVerifierTests

gh783_intervalFullyEmitted() - 类 中的方法reactor.test.StepVerifierTests

gh783_withInnerFlatmap() - 类 中的方法reactor.test.StepVerifierTests

gh841_iteratorFromCreate() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh841_streamCreate() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh841_streamCreateDeferredError() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh841_streamFromIterable() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh841_workaroundFlux() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh841_workaroundStream() - 类 中的方法reactor.core.publisher.BlockingIterableTest

gh870() - 类 中的方法reactor.core.publisher.FluxPublishMulticastTest

gh951_withConsumerInSubscribe() - 类 中的方法reactor.core.publisher.FluxDoFinallyTest

gh951_withoutConsumerInSubscribe() - 类 中的方法reactor.core.publisher.FluxDoFinallyTest

givenScenarioWrapped() - 类 中的方法reactor.test.MessageFormatterTest

groupBy(Function<? super T, ? extends K>) - 类 中的方法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) - 类 中的方法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>) - 类 中的方法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) - 类 中的方法reactor.core.publisher.Flux

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

groupByComplete() - 类 中的方法reactor.core.publisher.scenarios.FluxWindowConsistencyTest

groupByInnerCancel() - 类 中的方法reactor.core.publisher.scenarios.FluxWindowConsistencyTest

groupByMainCancel() - 类 中的方法reactor.core.publisher.scenarios.FluxWindowConsistencyTest

groupByMainCancelNoNewWindow() - 类 中的方法reactor.core.publisher.scenarios.FluxWindowConsistencyTest

GroupedFlux<K,V> - reactor.core.publisher中的类

Represents a sequence of events which has an associated key.

GroupedFlux() - 类 的构造器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>) - 类 中的方法reactor.core.publisher.Flux

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

groupMerge() - 类 中的方法reactor.core.publisher.ParallelFluxTest

groups() - 类 中的方法reactor.core.publisher.ParallelFlux

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

groupsCompleteAsSoonAsMainCompletes() - 类 中的方法reactor.core.publisher.FluxGroupByTest

groupsCompleteAsSoonAsMainCompletesNoFusion() - 类 中的方法reactor.core.publisher.FluxGroupByTest

guard - 类 中的变量reactor.core.publisher.StressSubscriber

guardedAgainstMultipleOnNext() - 类 中的方法reactor.core.publisher.MonoDelayElementTest

guardedAgainstOnComplete() - 类 中的方法reactor.core.publisher.MonoDelayElementTest

guardedAgainstOnError() - 类 中的方法reactor.core.publisher.MonoDelayElementTest

GuideDebuggingExtraTests - reactor.guide中的类

GuideDebuggingExtraTests() - 类 的构造器reactor.guide.GuideDebuggingExtraTests

GuideTests - reactor.guide中的类

Tests mirroring snippets from the reference documentation.

GuideTests() - 类 的构造器reactor.guide.GuideTests

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