StepVerifier.Step (reactor-3)

类型参数:

T - the type of values that the subscriber contains

所有超级接口:

StepVerifier.LastStep

所有已知子接口:

StepVerifier.FirstStep<T>

封闭接口:

StepVerifier
```
public static interface StepVerifier.Step<T>
extends StepVerifier.LastStep
```
Define a builder for expecting main sequence individual signals.

方法概要

所有方法实例方法抽象方法默认方法
限定符和类型	方法和说明
`StepVerifier.Step<T>`	`as(java.lang.String description)` Set a description for the previous verification step.
`default StepVerifier.Step<T>`	`assertNext(java.util.function.Consumer<? super T> assertionConsumer)` Expect an element and consume it with the given consumer, usually performing assertions on it (eg. using Hamcrest, AssertJ or JUnit assertion methods).
`StepVerifier.Step<T>`	`consumeNextWith(java.util.function.Consumer<? super T> consumer)` Expect an element and consume with the given consumer.Any `AssertionError`s thrown by the consumer will be rethrown during verification.
`StepVerifier.Step<T>`	`consumeRecordedWith(java.util.function.Consumer<? super java.util.Collection<T>> consumer)` Expect a recording session started via `recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>)`, end it and verify it by applying the given consumer.
`StepVerifier.Step<T>`	`consumeSubscriptionWith(java.util.function.Consumer<? super org.reactivestreams.Subscription> consumer)` Expect a `Subscription` and consume with the given consumer.
`StepVerifier.ContextExpectations<T>`	`expectAccessibleContext()` Expect that after the `Subscription` step, a `Context` has been propagated.
`StepVerifier.Step<T>`	`expectNext(T... ts)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNext(T t)` Expect the next element received to be equal to the given value.
`StepVerifier.Step<T>`	`expectNext(T t1, T t2)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNext(T t1, T t2, T t3)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNext(T t1, T t2, T t3, T t4)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNext(T t1, T t2, T t3, T t4, T t5)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNext(T t1, T t2, T t3, T t4, T t5, T t6)` Expect the next elements received to be equal to the given values.
`StepVerifier.Step<T>`	`expectNextCount(long count)` Expect to received `count` elements, starting from the previous expectation or onSubscribe.
`StepVerifier.Step<T>`	`expectNextMatches(java.util.function.Predicate<? super T> predicate)` Expect an element and evaluate with the given predicate.
`StepVerifier.Step<T>`	`expectNextSequence(java.lang.Iterable<? extends T> iterable)` Expect the next elements to match the given `Iterable` until its iterator depletes.
`StepVerifier.Step<T>`	`expectNoAccessibleContext()` Expect that NO `Context` was propagated after the `Subscription` phase, which usually indicates that the sequence under test doesn't contain Reactor operators (i.e. external Publisher, just a scalar source...).
`StepVerifier.Step<T>`	`expectNoEvent(java.time.Duration duration)` Expect that no event has been observed by the verifier for the length of the provided `Duration`.
`StepVerifier.Step<T>`	`expectRecordedMatches(java.util.function.Predicate<? super java.util.Collection<T>> predicate)` Expect a recording session started via `recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>)`, end it and verify it by ensuring the provided predicate matches.
`StepVerifier.Step<T>`	`recordWith(java.util.function.Supplier<? extends java.util.Collection<T>> supplier)` Start a recording session storing `Subscriber.onNext(Object)` values in the supplied `Collection`.
`StepVerifier.Step<T>`	`then(java.lang.Runnable task)` Run an arbitrary task scheduled after previous expectations or tasks.
`default StepVerifier.Step<T>`	`thenAwait()` Mark a Pause in the expectation evaluation.
`StepVerifier.Step<T>`	`thenAwait(java.time.Duration timeshift)` Pause the expectation evaluation for a given `Duration`.
`StepVerifier.Step<T>`	`thenConsumeWhile(java.util.function.Predicate<T> predicate)` Consume further onNext signals as long as they match a predicate.
`StepVerifier.Step<T>`	`thenConsumeWhile(java.util.function.Predicate<T> predicate, java.util.function.Consumer<T> consumer)` Consume further onNext signals using a provided `Consumer` as long as they match a `Predicate`.
`StepVerifier.Step<T>`	`thenRequest(long n)` Request the given amount of elements from the upstream `Publisher`.

从接口继承的方法 reactor.test.StepVerifier.LastStep
consumeErrorWith, expectComplete, expectError, expectError, expectErrorMatches, expectErrorMessage, expectErrorSatisfies, expectTimeout, thenCancel, verifyComplete, verifyError, verifyError, verifyErrorMatches, verifyErrorMessage, verifyErrorSatisfies, verifyTimeout

- 方法详细资料
  - as
```
StepVerifier.Step<T> as(java.lang.String description)
```
    Set a description for the previous verification step. Choosing a unique and descriptive name can make assertion errors easier to resolve.
    Note that calling this several times in a row will only take the first description into account.
    
    参数:
    
    description - the description for the previous verification step
    
    返回:
    
    this builder
  - consumeNextWith
```
StepVerifier.Step<T> consumeNextWith(java.util.function.Consumer<? super T> consumer)
```
    Expect an element and consume with the given consumer.Any AssertionErrors thrown by the consumer will be rethrown during verification.
    
    参数:
    
    consumer - the consumer for the value
    
    返回:
    
    this builder
  - assertNext
```
default StepVerifier.Step<T> assertNext(java.util.function.Consumer<? super T> assertionConsumer)
```
    Expect an element and consume it with the given consumer, usually performing assertions on it (eg. using Hamcrest, AssertJ or JUnit assertion methods). Alias for consumeNextWith(Consumer) for better discoverability of that use case.
    Any AssertionErrors thrown by the consumer will be rethrown during verification.
    
    参数:
    
    assertionConsumer - the consumer for the value, performing assertions
    
    返回:
    
    this builder
  - consumeRecordedWith
```
StepVerifier.Step<T> consumeRecordedWith(java.util.function.Consumer<? super java.util.Collection<T>> consumer)
```
    Expect a recording session started via recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>), end it and verify it by applying the given consumer. Any AssertionErrors thrown by the consumer will be rethrown during verification.
    
    参数:
    
    consumer - the consumer used to apply assertions on the recorded session
    
    返回:
    
    this builder
  - expectNext
```
StepVerifier.Step<T> expectNext(T t)
```
    Expect the next element received to be equal to the given value.
    
    参数:
    
    t - the value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T t1,
                                T t2)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    t1 - the first value to expect
    
    t2 - the second value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T t1,
                                T t2,
                                T t3)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    t1 - the first value to expect
    
    t2 - the second value to expect
    
    t3 - the third value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T t1,
                                T t2,
                                T t3,
                                T t4)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    t1 - the first value to expect
    
    t2 - the second value to expect
    
    t3 - the third value to expect
    
    t4 - the fourth value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T t1,
                                T t2,
                                T t3,
                                T t4,
                                T t5)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    t1 - the first value to expect
    
    t2 - the second value to expect
    
    t3 - the third value to expect
    
    t4 - the fourth value to expect
    
    t5 - the fifth value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T t1,
                                T t2,
                                T t3,
                                T t4,
                                T t5,
                                T t6)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    t1 - the first value to expect
    
    t2 - the second value to expect
    
    t3 - the third value to expect
    
    t4 - the fourth value to expect
    
    t5 - the fifth value to expect
    
    t6 - the sixth value to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNext
```
StepVerifier.Step<T> expectNext(T... ts)
```
    Expect the next elements received to be equal to the given values.
    
    参数:
    
    ts - the values to expect
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNextCount
```
StepVerifier.Step<T> expectNextCount(long count)
```
    Expect to received count elements, starting from the previous expectation or onSubscribe.
    
    参数:
    
    count - the number of emitted items to expect.
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNextSequence
```
StepVerifier.Step<T> expectNextSequence(java.lang.Iterable<? extends T> iterable)
```
    Expect the next elements to match the given Iterable until its iterator depletes.
    
    参数:
    
    iterable - the iterable containing the next expected values
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - expectNextMatches
```
StepVerifier.Step<T> expectNextMatches(java.util.function.Predicate<? super T> predicate)
```
    Expect an element and evaluate with the given predicate.
    
    参数:
    
    predicate - the predicate to test on the next received value
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - consumeSubscriptionWith
```
StepVerifier.Step<T> consumeSubscriptionWith(java.util.function.Consumer<? super org.reactivestreams.Subscription> consumer)
```
    Expect a Subscription and consume with the given consumer. Any AssertionErrors thrown by the consumer will be rethrown during verification.
    
    参数:
    
    consumer - the consumer for the Subscription
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onSubscribe(Subscription)
  - expectAccessibleContext
```
StepVerifier.ContextExpectations<T> expectAccessibleContext()
```
    Expect that after the Subscription step, a Context has been propagated. You can continue with assertions on said Context, and you will need to use StepVerifier.ContextExpectations.then() to switch back to verifying the sequence itself.
    
    返回:
    
    a StepVerifier.ContextExpectations for further assertion of the propagated Context
  - expectNoAccessibleContext
```
StepVerifier.Step<T> expectNoAccessibleContext()
```
    Expect that NO Context was propagated after the Subscription phase, which usually indicates that the sequence under test doesn't contain Reactor operators (i.e. external Publisher, just a scalar source...).
    
    返回:
    
    this builder for further assertion of the sequence
  - expectNoEvent
```
StepVerifier.Step<T> expectNoEvent(java.time.Duration duration)
```
    Expect that no event has been observed by the verifier for the length of the provided Duration. If virtual time is used, this duration is verified using the virtual clock.
    Note that you should only use this method as the first expectation if you actually don't expect a subscription to happen. Use StepVerifier.FirstStep.expectSubscription() combined with expectNoEvent(Duration) to work around that.
    Also avoid using this method at the end of the set of expectations: prefer StepVerifier.LastStep.expectTimeout(Duration) rather than expectNoEvent(...).thenCancel().
    
    参数:
    
    duration - the duration for which to observe no event has been received
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber
  - expectRecordedMatches
```
StepVerifier.Step<T> expectRecordedMatches(java.util.function.Predicate<? super java.util.Collection<T>> predicate)
```
    Expect a recording session started via recordWith(java.util.function.Supplier<? extends java.util.Collection<T>>), end it and verify it by ensuring the provided predicate matches.
    
    参数:
    
    predicate - the predicate to test on the recorded session
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscriber.onNext(Object)
  - recordWith
```
StepVerifier.Step<T> recordWith(java.util.function.Supplier<? extends java.util.Collection<T>> supplier)
```
    Start a recording session storing Subscriber.onNext(Object) values in the supplied Collection. Further steps expectRecordedMatches(Predicate) and consumeRecordedWith(Consumer) can consume and assert the session.
    If an existing recording session hasn't not been declaratively consumed, this step will override the current session.
    
    参数:
    
    supplier - the supplier for the Collection to use for recording.
    
    返回:
    
    this builder
  - then
```
StepVerifier.Step<T> then(java.lang.Runnable task)
```
    Run an arbitrary task scheduled after previous expectations or tasks.
    
    参数:
    
    task - the task to run
    
    返回:
    
    this builder
  - thenAwait
```
default StepVerifier.Step<T> thenAwait()
```
    Mark a Pause in the expectation evaluation. If a VirtualTimeScheduler has been configured, VirtualTimeScheduler.advanceTime() will be used and the pause will not block testing or Publisher thread.
    
    返回:
    
    this builder
  - thenAwait
```
StepVerifier.Step<T> thenAwait(java.time.Duration timeshift)
```
    Pause the expectation evaluation for a given Duration. If a VirtualTimeScheduler has been configured, VirtualTimeScheduler.advanceTimeBy(Duration) will be used and the pause will not block testing or Publisher thread.
    
    参数:
    
    timeshift - a pause Duration
    
    返回:
    
    this builder
  - thenConsumeWhile
```
StepVerifier.Step<T> thenConsumeWhile(java.util.function.Predicate<T> predicate)
```
    Consume further onNext signals as long as they match a predicate.
    
    参数:
    
    predicate - the condition to continue consuming onNext
    
    返回:
    
    this builder
  - thenConsumeWhile
```
StepVerifier.Step<T> thenConsumeWhile(java.util.function.Predicate<T> predicate,
                                      java.util.function.Consumer<T> consumer)
```
    Consume further onNext signals using a provided Consumer as long as they match a Predicate. You can use the consumer to apply assertions on each value.
    
    参数:
    
    predicate - the condition to continue consuming onNext
    
    consumer - the consumer to use to consume the data, when the predicate matches
    
    返回:
    
    this builder
  - thenRequest
```
StepVerifier.Step<T> thenRequest(long n)
```
    Request the given amount of elements from the upstream Publisher. This is in addition to the initial number of elements requested by an initial passed demand like with StepVerifier.create(Publisher, long).
    
    参数:
    
    n - the number of elements to request
    
    返回:
    
    this builder
    
    另请参阅:
    
    Subscription.request(long)

接口 StepVerifier.Step<T>

方法概要

从接口继承的方法 reactor.test.StepVerifier.LastStep

方法详细资料

as

consumeNextWith

assertNext

consumeRecordedWith

expectNext

expectNext

expectNext

expectNext

expectNext

expectNext

expectNext

expectNextCount

expectNextSequence

expectNextMatches

consumeSubscriptionWith

expectAccessibleContext

expectNoAccessibleContext

expectNoEvent

expectRecordedMatches

recordWith

then

thenAwait

thenAwait

thenConsumeWhile

thenConsumeWhile

thenRequest