Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
PublisherVerification
✓ org.reactivestreams.tck.PublisherVerification
Test a Publisher implementation for Reactive Streams compliance.
import org.reactivestreams.tck.PublisherVerification;
import org.reactivestreams.Publisher;
public class MyPublisherTest extends PublisherVerification<Integer> {
public MyPublisherTest() {
super(new TestEnvironment());
}
@Override
public Publisher<Integer> createPublisher(long elements) {
return subscriber -> {
for (int i = 0; i < elements; i++) subscriber.onNext(i);
subscriber.onComplete();
};
}
@Override
public Publisher<Integer> createFailedPublisher() {
return subscriber -> subscriber.onError(new RuntimeException("fail"));
}
}
Debug
Known issues
No known issues recorded.
Audit
Dependencies
No dependency data recorded yet.