public class ReactiveStreamsPublisherTckTest
extends org.reactivestreams.tck.PublisherVerification<javax.ws.rs.sse.InboundSseEvent>
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_RECURSION_DEPTH |
protected static int |
DEFAULT_TIMEOUT |
Constructor and Description |
---|
ReactiveStreamsPublisherTckTest() |
Modifier and Type | Method and Description |
---|---|
long |
boundedDepthOfOnNextAndRequestRecursion() |
static org.jboss.shrinkwrap.api.spec.WebArchive |
createDeployment() |
org.reactivestreams.Publisher<javax.ws.rs.sse.InboundSseEvent> |
createFailedPublisher() |
org.reactivestreams.Publisher<javax.ws.rs.sse.InboundSseEvent> |
createPublisher(long elements) |
activePublisherTest, envPublisherReferenceGCTimeoutMillis, maxElementsFromPublisher, notVerified, notVerified, optional_spec104_mustSignalOnErrorWhenFails, optional_spec105_emptyStreamMustTerminateBySignallingOnComplete, optional_spec111_maySupportMultiSubscribe, optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfront, optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingManyUpfrontAndCompleteAsExpected, optional_spec111_multicast_mustProduceTheSameElementsInTheSameSequenceToAllOfItsSubscribersWhenRequestingOneByOne, optional_spec111_registeredSubscribersMustReceiveOnNextOrOnCompleteSignals, optional_spec309_requestNegativeNumberMaySignalIllegalArgumentExceptionWithSpecificMessage, optionalActivePublisherTest, potentiallyPendingTest, potentiallyPendingTest, publisherUnableToSignalOnComplete, required_createPublisher1MustProduceAStreamOfExactly1Element, required_createPublisher3MustProduceAStreamOfExactly3Elements, required_spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements, required_spec102_maySignalLessThanRequestedAndTerminateSubscription, required_spec105_mustSignalOnCompleteWhenFiniteStreamTerminates, required_spec107_mustNotEmitFurtherSignalsOnceOnCompleteHasBeenSignalled, required_spec109_mayRejectCallsToSubscribeIfPublisherIsUnableOrUnwillingToServeThemRejectionMustTriggerOnErrorAfterOnSubscribe, required_spec109_mustIssueOnSubscribeForNonNullSubscriber, required_spec109_subscribeThrowNPEOnNullSubscriber, required_spec302_mustAllowSynchronousRequestCallsFromOnNextAndOnSubscribe, required_spec303_mustNotAllowUnboundedRecursion, required_spec306_afterSubscriptionIsCancelledRequestMustBeNops, required_spec307_afterSubscriptionIsCancelledAdditionalCancelationsMustBeNops, required_spec309_requestNegativeNumberMustSignalIllegalArgumentException, required_spec309_requestZeroMustSignalIllegalArgumentException, required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling, required_spec313_cancelMustMakeThePublisherEventuallyDropAllReferencesToTheSubscriber, required_spec317_mustNotSignalOnErrorWhenPendingAboveLongMaxValue, required_spec317_mustSupportACumulativePendingElementCountUpToLongMaxValue, required_spec317_mustSupportAPendingElementCountUpToLongMaxValue, required_validate_boundedDepthOfOnNextAndRequestRecursion, required_validate_maxElementsFromPublisher, setUp, skipStochasticTests, stochastic_spec103_mustSignalOnMethodsSequentially, stochasticTest, untested_spec106_mustConsiderSubscriptionCancelledAfterOnErrorOrOnCompleteHasBeenCalled, untested_spec107_mustNotEmitFurtherSignalsOnceOnErrorHasBeenSignalled, untested_spec108_possiblyCanceledSubscriptionShouldNotReceiveOnErrorOrOnCompleteSignals, untested_spec109_subscribeShouldNotThrowNonFatalThrowable, untested_spec110_rejectASubscriptionRequestIfTheSameSubscriberSubscribesTwice, untested_spec304_requestShouldNotPerformHeavyComputations, untested_spec305_cancelMustNotSynchronouslyPerformHeavyComputation, whenHasErrorPublisherTest
protected static final int DEFAULT_TIMEOUT
protected static final int DEFAULT_RECURSION_DEPTH
@Deployment public static org.jboss.shrinkwrap.api.spec.WebArchive createDeployment()
public long boundedDepthOfOnNextAndRequestRecursion()
boundedDepthOfOnNextAndRequestRecursion
in class org.reactivestreams.tck.PublisherVerification<javax.ws.rs.sse.InboundSseEvent>
public org.reactivestreams.Publisher<javax.ws.rs.sse.InboundSseEvent> createFailedPublisher()
createFailedPublisher
in class org.reactivestreams.tck.PublisherVerification<javax.ws.rs.sse.InboundSseEvent>
public org.reactivestreams.Publisher<javax.ws.rs.sse.InboundSseEvent> createPublisher(long elements)
createPublisher
in class org.reactivestreams.tck.PublisherVerification<javax.ws.rs.sse.InboundSseEvent>
Copyright © 2021 Eclipse Foundation. All rights reserved.