TestPublisher (reactor-3)

java.lang.Object
- reactor.test.publisher.TestPublisher<T>

所有已实现的接口:

org.reactivestreams.Publisher<T>, PublisherProbe<T>
```
public abstract class TestPublisher<T>
extends java.lang.Object
implements org.reactivestreams.Publisher<T>, PublisherProbe<T>
```
A Publisher that you can directly manipulate, triggering onNext, onComplete and onError events, for testing purposes. You can assert the state of the publisher using its assertXXX methods, usually inside a StepVerifier's then callback.
The TestPublisher can also be made more lenient towards the RS spec and allow "spec violations", as enumerated in TestPublisher.Violation. Use the createNoncompliant(Violation, Violation...) factory method to create such a misbehaving publisher.
TestPublisher are generally hot, directly propagating signals to currently subscribed downstreams and only replaying the first termination signal to subsequent subscribers. TestPublishers are also generally not safe to use from multiple parallel threads.

作者:

Simon Basle

嵌套类概要

嵌套类
限定符和类型类和说明

static class TestPublisher.Violation
Possible misbehavior for a TestPublisher.
- 从接口继承的嵌套类/接口 reactor.test.publisher.PublisherProbe
  PublisherProbe.DefaultPublisherProbe<T>

嵌套类
限定符和类型	类和说明
`static class`	`TestPublisher.Violation` Possible misbehavior for a `TestPublisher`.

构造器概要

构造器
构造器和说明

TestPublisher()

构造器
构造器和说明
`TestPublisher()`

方法概要

所有方法静态方法实例方法抽象方法具体方法
限定符和类型	方法和说明
`abstract TestPublisher<T>`	`assertCancelled()` Asserts that this publisher has had at least one subscriber that has been cancelled.
`abstract TestPublisher<T>`	`assertCancelled(int n)` Asserts that this publisher has had at least n subscribers that have been cancelled.
`abstract TestPublisher<T>`	`assertMaxRequested(long n)` Assert that the current maximum request of all this publisher's subscribers is <= `n`.
`abstract TestPublisher<T>`	`assertMinRequested(long n)` Assert that the current minimum request of all this publisher's subscribers is >= `n`.
`abstract TestPublisher<T>`	`assertNoRequestOverflow()` Asserts that this publisher has had no subscriber with request overflow.
`abstract TestPublisher<T>`	`assertNoSubscribers()` Asserts that this publisher has no subscribers.
`abstract TestPublisher<T>`	`assertNotCancelled()` Asserts that this publisher has had no cancelled subscribers.
`abstract TestPublisher<T>`	`assertRequestOverflow()` Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.
`abstract TestPublisher<T>`	`assertSubscribers()` Asserts that this publisher has subscribers.
`abstract TestPublisher<T>`	`assertSubscribers(int n)` Asserts that this publisher has exactly n subscribers.
`abstract TestPublisher<T>`	`complete()` Triggers `completion` of this publisher.
`static <T> TestPublisher<T>`	`create()` Create a standard hot `TestPublisher`.
`static <T> TestPublisher<T>`	`createCold()` Create a cold `TestPublisher`, which can be subscribed to by multiple subscribers.
`static <T> TestPublisher<T>`	`createColdNonBuffering()` Create a cold `TestPublisher`, which can be subscribed to by multiple subscribers.
`static <T> TestPublisher<T>`	`createColdNonCompliant(boolean errorOnOverflow, TestPublisher.Violation firstViolation, TestPublisher.Violation... otherViolations)` Create a cold `TestPublisher`, which can be subscribed to by multiple subscribers.
`static <T> TestPublisher<T>`	`createNoncompliant(TestPublisher.Violation first, TestPublisher.Violation... rest)` Create a `noncompliant` hot `TestPublisher` with a given set of reactive streams spec violations that will be overlooked.
`TestPublisher<T>`	`emit(T... values)` Combine emitting items and completing this publisher.
`abstract TestPublisher<T>`	`error(java.lang.Throwable t)` Triggers an `error` signal to the subscribers.
`abstract Flux<T>`	`flux()` Convenience method to wrap this `TestPublisher` to a `Flux`.
`abstract Mono<T>`	`mono()` Convenience method to wrap this `TestPublisher` to a `Mono`.
`abstract TestPublisher<T>`	`next(T value)` Send 1 `onNext` signal to the subscribers.
`TestPublisher<T>`	`next(T first, T... rest)` Send 1-n `onNext` signals to the subscribers.

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.reactivestreams.Publisher
subscribe

从接口继承的方法 reactor.test.publisher.PublisherProbe
assertWasCancelled, assertWasNotCancelled, assertWasNotRequested, assertWasNotSubscribed, assertWasRequested, assertWasSubscribed, empty, of, subscribeCount, wasCancelled, wasRequested, wasSubscribed

- 构造器详细资料
  - TestPublisher
```
public TestPublisher()
```
- 方法详细资料
  - create
```
public static <T> TestPublisher<T> create()
```
    Create a standard hot TestPublisher.
    
    类型参数:
    
    T - the type of the publisher
    
    返回:
    
    the new TestPublisher
  - createNoncompliant
```
public static <T> TestPublisher<T> createNoncompliant(TestPublisher.Violation first,
                                                      TestPublisher.Violation... rest)
```
    Create a noncompliant hot TestPublisher with a given set of reactive streams spec violations that will be overlooked.
    
    类型参数:
    
    T - the type of the publisher
    
    参数:
    
    first - the first allowed TestPublisher.Violation
    
    rest - additional optional violations
    
    返回:
    
    the new noncompliant TestPublisher
  - createCold
```
public static <T> TestPublisher<T> createCold()
```
    Create a cold TestPublisher, which can be subscribed to by multiple subscribers. It buffers the next(Object) events and tracks how many elements have been seen by each subscriber in order to correctly replay the buffer.
    The publisher honors backpressure, holding off emitting newest items from the buffer if the subscriber doesn't have enough request.
    
    类型参数:
    
    T - the type of the publisher
    
    返回:
    
    the new TestPublisher
  - createColdNonBuffering
```
public static <T> TestPublisher<T> createColdNonBuffering()
```
    Create a cold TestPublisher, which can be subscribed to by multiple subscribers. It buffers the next(Object) events and tracks how many elements have been seen by each subscriber in order to correctly replay the buffer.
    The returned publisher will emit an overflow error if a new subscriber's first request is lower than the current buffer size, or if a new element is pushed to a registered subscriber that has zero pending demand.
    
    类型参数:
    
    T - the type of the publisher
    
    返回:
    
    the new TestPublisher
  - createColdNonCompliant
```
public static <T> TestPublisher<T> createColdNonCompliant(boolean errorOnOverflow,
                                                          TestPublisher.Violation firstViolation,
                                                          TestPublisher.Violation... otherViolations)
```
    Create a cold TestPublisher, which can be subscribed to by multiple subscribers. It buffers the next(Object) events and tracks how many elements have been seen by each subscriber in order to correctly replay the buffer.
    The returned publisher will be non-compliant to the spec according to one or more TestPublisher.Violations. In addition, its behavior when there is more data than requested can be set via errorOnOverflow.
    
    类型参数:
    
    T - the type of the publisher
    
    参数:
    
    errorOnOverflow - whether to throw an exception if there are more values than request (true) or buffer values until request becomes available (false)
    
    返回:
    
    the new TestPublisher
  - flux
```
public abstract Flux<T> flux()
```
    Convenience method to wrap this TestPublisher to a Flux.
    
    指定者:
    
    flux 在接口中 PublisherProbe<T>
    
    返回:
    
    a Flux version of the probe.
  - mono
```
public abstract Mono<T> mono()
```
    Convenience method to wrap this TestPublisher to a Mono.
    
    指定者:
    
    mono 在接口中 PublisherProbe<T>
    
    返回:
    
    a Mono version of the probe.
  - assertMinRequested
```
public abstract TestPublisher<T> assertMinRequested(long n)
```
    Assert that the current minimum request of all this publisher's subscribers is >= n.
    
    参数:
    
    n - the expected minimum request
    
    返回:
    
    this TestPublisher for chaining.
  - assertMaxRequested
```
public abstract TestPublisher<T> assertMaxRequested(long n)
```
    Assert that the current maximum request of all this publisher's subscribers is <= n. Can be Long.MAX_VALUE in case a subscriber has made an unbounded request.
    
    参数:
    
    n - the expected maximum request including Long.MAX_VALUE
    
    返回:
    
    this TestPublisher for chaining.
  - assertSubscribers
```
public abstract TestPublisher<T> assertSubscribers()
```
    Asserts that this publisher has subscribers.
    
    返回:
    
    this TestPublisher for chaining.
  - assertSubscribers
```
public abstract TestPublisher<T> assertSubscribers(int n)
```
    Asserts that this publisher has exactly n subscribers.
    
    参数:
    
    n - the expected number of subscribers
    
    返回:
    
    this TestPublisher for chaining.
  - assertNoSubscribers
```
public abstract TestPublisher<T> assertNoSubscribers()
```
    Asserts that this publisher has no subscribers.
    
    返回:
    
    this TestPublisher for chaining.
  - assertCancelled
```
public abstract TestPublisher<T> assertCancelled()
```
    Asserts that this publisher has had at least one subscriber that has been cancelled.
    
    返回:
    
    this TestPublisher for chaining.
  - assertCancelled
```
public abstract TestPublisher<T> assertCancelled(int n)
```
    Asserts that this publisher has had at least n subscribers that have been cancelled.
    
    参数:
    
    n - the expected number of subscribers to have been cancelled.
    
    返回:
    
    this TestPublisher for chaining.
  - assertNotCancelled
```
public abstract TestPublisher<T> assertNotCancelled()
```
    Asserts that this publisher has had no cancelled subscribers.
    
    返回:
    
    this TestPublisher for chaining.
  - assertRequestOverflow
```
public abstract TestPublisher<T> assertRequestOverflow()
```
    Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.
    
    返回:
    
    this TestPublisher for chaining.
  - assertNoRequestOverflow
```
public abstract TestPublisher<T> assertNoRequestOverflow()
```
    Asserts that this publisher has had no subscriber with request overflow. Request overflow is receiving an onNext event despite having a requested amount of 0 at that time.
    
    返回:
    
    this TestPublisher for chaining.
  - next
```
public abstract TestPublisher<T> next(@Nullable
                                      T value)
```
    Send 1 onNext signal to the subscribers.
    
    参数:
    
    value - the item to emit (can be null if the relevant TestPublisher.Violation is set)
    
    返回:
    
    this TestPublisher for chaining.
  - error
```
public abstract TestPublisher<T> error(java.lang.Throwable t)
```
    Triggers an error signal to the subscribers.
    
    参数:
    
    t - the Throwable to trigger
    
    返回:
    
    this TestPublisher for chaining.
  - complete
```
public abstract TestPublisher<T> complete()
```
    Triggers completion of this publisher.
    
    返回:
    
    this TestPublisher for chaining.
  - next
```
@SafeVarargs
public final TestPublisher<T> next(@Nullable
                                                 T first,
                                                 T... rest)
```
    Send 1-n onNext signals to the subscribers.
    
    参数:
    
    first - the first item to emit
    
    rest - the optional remaining items to emit
    
    返回:
    
    this TestPublisher for chaining.
    
    另请参阅:
    
    next
  - emit
```
@SafeVarargs
public final TestPublisher<T> emit(T... values)
```
    Combine emitting items and completing this publisher.
    
    参数:
    
    values - the values to emit to subscribers
    
    返回:
    
    this TestPublisher for chaining.
    
    另请参阅:
    
    next, complete

类 TestPublisher<T>

嵌套类概要

从接口继承的嵌套类/接口 reactor.test.publisher.PublisherProbe

构造器概要

方法概要

从类继承的方法 java.lang.Object

从接口继承的方法 org.reactivestreams.Publisher

从接口继承的方法 reactor.test.publisher.PublisherProbe

构造器详细资料

TestPublisher

方法详细资料

create

createNoncompliant

createCold

createColdNonBuffering

createColdNonCompliant

flux

mono

assertMinRequested

assertMaxRequested

assertSubscribers

assertSubscribers

assertNoSubscribers

assertCancelled

assertCancelled

assertNotCancelled

assertRequestOverflow

assertNoRequestOverflow

next

error

complete

next

emit