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

H

handle(BiConsumer<? super T, SynchronousSink<R>>) - Method in class reactor.core.publisher.Flux

Handle the items emitted by this Flux by calling a biconsumer with the output sink for each onNext.

handle(BiConsumer<? super T, SynchronousSink<R>>) - Method in class reactor.core.publisher.Mono

Handle the items emitted by this Mono by calling a biconsumer with the output sink for each onNext.

handleListenerError(Throwable) - Method in class reactor.core.observability.DefaultSignalListener

handleListenerError(Throwable) - Method in interface reactor.core.observability.SignalListener

A special handler for exceptions thrown from all the other handlers.

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

Deprecated.

Return true if terminated with onComplete

hasDiscarded(Object...) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has discarded at least all of the provided elements to the discard hook, in any order.

hasDiscardedElements() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has discarded at least one element to the discard hook.

hasDiscardedElementsMatching(Predicate<Collection<Object>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has discarded one or more elements to the discard hook, and check that the collection of discarded elements matches a predicate.

hasDiscardedElementsSatisfying(Consumer<Collection<Object>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has discarded one or more elements to the discard hook, and assert them as a collection.

hasDiscardedExactly(Object...) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has discarded all of the provided elements to the discard hook, in any order, and that no other elements were dropped.

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

Deprecated.

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

Deprecated.

Return true if any Subscriber is actively subscribed

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

Deprecated.

Return true if any Subscriber is actively subscribed

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

Deprecated.

hasDropped(Object...) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped at least all of the provided elements to the Hooks.onNextDropped(Consumer) hook, in any order.

hasDroppedElements() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped at least one element to the Hooks.onNextDropped(Consumer) hook.

hasDroppedErrorMatching(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped exactly one error matching the given predicate to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedErrorOfType(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped exactly one error of the given type to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedErrors() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped at least one error to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedErrors(int) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped exactly n errors to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedErrorsMatching(Predicate<Collection<Throwable>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped one or more errors to the Hooks.onErrorDropped(Consumer) hook, and check that the collection of errors matches a predicate.

hasDroppedErrorsSatisfying(Consumer<Collection<Throwable>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped one or more errors to the Hooks.onErrorDropped(Consumer) hook, and assert them as a collection.

hasDroppedErrorWithMessage(String) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped exactly one error with the exact provided message to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedErrorWithMessageContaining(String) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped exactly one error with a message containing the provided string to the Hooks.onErrorDropped(Consumer) hook.

hasDroppedExactly(Object...) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has dropped all of the provided elements to the Hooks.onNextDropped(Consumer) hook, in any order, and that no other elements were dropped.

hasElement(T) - Method in class reactor.core.publisher.Flux

Emit a single boolean true if any of the elements of this Flux sequence is equal to the provided value.

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

Emit a single boolean true if this Mono has an element.

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

Emit a single boolean true if this Flux sequence has at least one element.

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

Deprecated.

Return true if terminated with onError

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

Read whether this signal is on error and carries the cause.

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

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

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

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

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

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

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

hasKey(Object) - Method in interface reactor.test.StepVerifier.ContextExpectations

Check that the propagated Context contains a value for the given key.

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

Return true if a particular key resolves to a value within the Context.

hasNotDiscardedElements() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has not discarded any element to the discard hook.

hasNotDroppedElements() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has not dropped any element to the Hooks.onNextDropped(Consumer) hook.

hasNotDroppedErrors() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has not dropped any error to the Hooks.onErrorDropped(Consumer) hook.

hasOperatorErrorMatching(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error matches the given predicate.

hasOperatorErrorOfType(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error is of the given type.

hasOperatorErrors() - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook at least once.

hasOperatorErrors(int) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook exactly n times.

hasOperatorErrorsMatching(Predicate<Collection<Tuple2<Optional<Throwable>, Optional<?>>>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook once or more, and check that the collection of errors and their optionally associated data matches a predicate.

hasOperatorErrorsSatisfying(Consumer<Collection<Tuple2<Optional<Throwable>, Optional<?>>>>) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook once or more, and assert the errors and optionally associated data as a collection.

hasOperatorErrorWithMessage(String) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook exactly once and the error has the exact provided message.

hasOperatorErrorWithMessageContaining(String) - Method in interface reactor.test.StepVerifier.Assertions

Assert that the tested publisher has triggered the onOperatorError hook exactly once, with the error message containing the provided string.

hasSize(int) - Method in interface reactor.test.StepVerifier.ContextExpectations

Check that the propagated Context is of the given size.

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

Has this signal an item associated with it ? (which only happens if it is an (onNext) signal)

hide() - Method in class reactor.core.publisher.ConnectableFlux

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

Hides the identities of this Flux instance.

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

Hides the identity of this Mono instance.

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

Hides the identities of this ParallelFlux and its Subscription as well.

hookFinally(SignalType) - Method in class reactor.core.publisher.BaseSubscriber

Optional hook executed after any of the termination events (onError, onComplete, cancel).

hookOnCancel() - Method in class reactor.core.publisher.BaseSubscriber

Optional hook executed when the subscription is cancelled by calling this Subscriber's BaseSubscriber.cancel() method.

hookOnComplete() - Method in class reactor.core.publisher.BaseSubscriber

Optional hook for completion processing.

hookOnError(Throwable) - Method in class reactor.core.publisher.BaseSubscriber

Optional hook for error processing.

hookOnNext(T) - Method in class reactor.core.publisher.BaseSubscriber

Hook for processing of onNext values.

hookOnSubscribe(Subscription) - Method in class reactor.core.publisher.BaseSubscriber

Hook for further processing of onSubscribe's Subscription.

Hooks - Class in reactor.core.publisher

A set of overridable lifecycle hooks that can be used for cross-cutting added behavior on Flux/Mono operators.

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