Package | Description |
---|---|
reactor.test.publisher |
Components supporting the creation of test-oriented
Publishers . |
Modifier and Type | Method and Description |
---|---|
static TestPublisher.Violation |
TestPublisher.Violation.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TestPublisher.Violation[] |
TestPublisher.Violation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static <T> TestPublisher<T> |
TestPublisher.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> |
TestPublisher.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> |
TestPublisher.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. |
static <T> TestPublisher<T> |
TestPublisher.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. |