org.reactivestreams.Publisher<T>
IdentityProcessorVerification.TestSetup
, SubscriberBlackboxVerification.BlackboxTestStage
, SubscriberWhiteboxVerification.WhiteboxTestStage
public static class TestEnvironment.ManualPublisher<T> extends java.lang.Object implements org.reactivestreams.Publisher<T>
Modifier and Type | Field | Description |
---|---|---|
protected TestEnvironment.Latch |
cancelled |
|
protected TestEnvironment |
env |
|
protected long |
pendingDemand |
|
protected TestEnvironment.Receptacle<java.lang.Long> |
requests |
|
protected TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> |
subscriber |
Constructor | Description |
---|---|
ManualPublisher(TestEnvironment env) |
Modifier and Type | Method | Description |
---|---|---|
void |
expectCancelling() |
|
void |
expectCancelling(long timeoutMillis) |
|
void |
expectExactRequest(long expected) |
|
void |
expectExactRequest(long expected,
long timeoutMillis) |
|
void |
expectNoRequest() |
|
void |
expectNoRequest(long timeoutMillis) |
|
long |
expectRequest() |
|
long |
expectRequest(long timeoutMillis) |
|
long |
expectRequest(long timeoutMillis,
java.lang.String errorMessageAddendum) |
|
boolean |
isCancelled() |
|
void |
sendCompletion() |
|
void |
sendError(java.lang.Throwable cause) |
|
void |
sendNext(T element) |
|
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |
protected final TestEnvironment env
protected long pendingDemand
protected TestEnvironment.Promise<org.reactivestreams.Subscriber<? super T>> subscriber
protected final TestEnvironment.Receptacle<java.lang.Long> requests
protected final TestEnvironment.Latch cancelled
public ManualPublisher(TestEnvironment env)
public void subscribe(org.reactivestreams.Subscriber<? super T> s)
subscribe
in interface org.reactivestreams.Publisher<T>
public void sendCompletion()
public void sendError(java.lang.Throwable cause)
public long expectRequest() throws java.lang.InterruptedException
java.lang.InterruptedException
public long expectRequest(long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public long expectRequest(long timeoutMillis, java.lang.String errorMessageAddendum) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectExactRequest(long expected) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectExactRequest(long expected, long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNoRequest() throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectNoRequest(long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectCancelling() throws java.lang.InterruptedException
java.lang.InterruptedException
public void expectCancelling(long timeoutMillis) throws java.lang.InterruptedException
java.lang.InterruptedException
public boolean isCancelled() throws java.lang.InterruptedException
java.lang.InterruptedException