程序包 | 说明 |
---|---|
reactor.test.subscriber |
Components supporting the creation of test-oriented
Subscribers . |
限定符和类型 | 方法和说明 |
---|---|
static TestSubscriberBuilder |
TestSubscriber.builder()
Create a
TestSubscriber with tuning. |
TestSubscriberBuilder |
TestSubscriberBuilder.contextPut(java.lang.Object key,
java.lang.Object value)
Enrich the
Context with a single entry. |
TestSubscriberBuilder |
TestSubscriberBuilder.contextPutAll(ContextView toAdd)
Enrich the
Context by putting all entries of the given ContextView in it. |
TestSubscriberBuilder |
TestSubscriberBuilder.initialRequest(long initialRequest)
Set the request to be made upon receiving the
Subscription
in Subscriber.onSubscribe(Subscription) . |
TestSubscriberBuilder |
TestSubscriberBuilder.initialRequestUnbounded()
Set the request to be made upon receiving the
Subscription
in Subscriber.onSubscribe(Subscription) to be an
unbounded request, ie. |
TestSubscriberBuilder |
TestSubscriberBuilder.requireFusion(int exactMode)
Expect fusion to be possible with the
TestSubscriber , with Fuseable.NONE ) being a special case. |
TestSubscriberBuilder |
TestSubscriberBuilder.requireFusion(int requestedMode,
int negotiatedMode)
Expect fusion to be possible with the
TestSubscriber , with both parameters set to Fuseable.NONE being a special case. |
TestSubscriberBuilder |
TestSubscriberBuilder.requireNotFuseable()
|