Uses of Interface
org.reactivestreams.Publisher
Packages that use Publisher
Package
Description
-
Uses of Publisher in org.reactivestreams
Subinterfaces of Publisher in org.reactivestreamsModifier and TypeInterfaceDescriptioninterface
Processor<T,
R> AProcessor
represents a processing stage—which is both aSubscriber
and aPublisher
and obeys the contracts of both.Classes in org.reactivestreams that implement PublisherModifier and TypeClassDescription(package private) static final class
Reactive Streams Publisher that wraps a Flow Publisher.(package private) static final class
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.Fields in org.reactivestreams declared as PublisherMethods in org.reactivestreams that return PublisherModifier and TypeMethodDescriptionstatic <T> Publisher
<T> FlowAdapters.toPublisher
(Flow.Publisher<? extends T> flowPublisher) Converts a Flow Publisher into a Reactive Streams Publisher.Methods in org.reactivestreams with parameters of type PublisherModifier and TypeMethodDescriptionstatic <T> Flow.Publisher
<T> FlowAdapters.toFlowPublisher
(Publisher<? extends T> reactiveStreamsPublisher) Converts a Reactive Streams Publisher into a Flow Publisher.Constructors in org.reactivestreams with parameters of type PublisherModifierConstructorDescriptionFlowPublisherFromReactive
(Publisher<? extends T> reactivePublisher) -
Uses of Publisher in org.reactivestreams.example.unicast
Classes in org.reactivestreams.example.unicast that implement PublisherModifier and TypeClassDescriptionclass
AsyncIterablePublisher is an implementation of Reactive Streams `Publisher` which executes asynchronously, using a provided `Executor` and produces elements from a given `Iterable` in a "unicast" configuration to its `Subscribers`.class
class
final class
A synchronous implementation of thePublisher
that can be subscribed to multiple times and each individual subscription will receive range of monotonically increasing integer values on demand. -
Uses of Publisher in org.reactivestreams.tck
Classes in org.reactivestreams.tck that implement PublisherModifier and TypeClassDescriptionclass
class
class
static class
Fields in org.reactivestreams.tck declared as PublisherModifier and TypeFieldDescriptionSubscriberBlackboxVerification.BlackboxTestStage.pub
SubscriberWhiteboxVerification.WhiteboxTestStage.pub
Methods in org.reactivestreams.tck that return PublisherModifier and TypeMethodDescriptionIdentityProcessorVerification.createFailedPublisher()
By implementing this method, additional TCK tests concerning a "failed" publishers will be run.PublisherVerification.createFailedPublisher()
By implementing this method, additional TCK tests concerning a "failed" publishers will be run.SubscriberBlackboxVerification.BlackboxTestStage.createHelperPublisher
(long elements) SubscriberWhiteboxVerification.WhiteboxTestStage.createHelperPublisher
(long elements) WithHelperPublisher.createHelperPublisher
(long elements) Helper method required for creating the Publisher to which the tested Subscriber will be subscribed and tested against.IdentityProcessorVerification.createPublisher
(long elements) PublisherVerification.createPublisher
(long elements) This is the main method you must implement in your test incarnation.Methods in org.reactivestreams.tck with parameters of type PublisherModifier and TypeMethodDescriptionTestEnvironment.newBlackholeSubscriber
(Publisher<T> pub) TestEnvironment.newManualSubscriber
(Publisher<T> pub) TestEnvironment.newManualSubscriber
(Publisher<T> pub, long timeoutMillis) void
PublisherVerification.potentiallyPendingTest
(Publisher<T> pub, PublisherVerification.PublisherTestRun<T> body) void
PublisherVerification.potentiallyPendingTest
(Publisher<T> pub, PublisherVerification.PublisherTestRun<T> body, String message) void
<T> void
TestEnvironment.subscribe
(Publisher<T> pub, TestEnvironment.TestSubscriber<T> sub) <T> void
TestEnvironment.subscribe
(Publisher<T> pub, TestEnvironment.TestSubscriber<T> sub, long timeoutMillis) -
Uses of Publisher in org.reactivestreams.tck.flow
Methods in org.reactivestreams.tck.flow that return PublisherModifier and TypeMethodDescriptionFlowPublisherVerification.createFailedPublisher()
IdentityFlowProcessorVerification.createFailedPublisher()
FlowPublisherVerification.createPublisher
(long elements) -
Uses of Publisher in org.reactivestreams.tck.flow.support
Classes in org.reactivestreams.tck.flow.support that implement Publisher