Uses of Interface
org.reactivestreams.Publisher
-
Packages that use Publisher Package Description org.reactivestreams org.reactivestreams.example.unicast org.reactivestreams.tck org.reactivestreams.tck.flow org.reactivestreams.tck.flow.support -
-
Uses of Publisher in org.reactivestreams
Subinterfaces of Publisher in org.reactivestreams Modifier and Type Interface Description interface
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 Publisher Modifier and Type Class Description (package private) static class
FlowAdapters.ReactivePublisherFromFlow<T>
Reactive Streams Publisher that wraps a Flow Publisher.(package private) static class
FlowAdapters.ReactiveToFlowProcessor<T,U>
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.Fields in org.reactivestreams declared as Publisher Modifier and Type Field Description (package private) Publisher<? extends T>
FlowAdapters.FlowPublisherFromReactive. reactiveStreams
Methods in org.reactivestreams that return Publisher Modifier and Type Method Description static <T> Publisher<T>
FlowAdapters. toPublisher(java.util.concurrent.Flow.Publisher<? extends T> flowPublisher)
Converts a Flow Publisher into a Reactive Streams Publisher.Methods in org.reactivestreams with parameters of type Publisher Modifier and Type Method Description static <T> java.util.concurrent.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 Publisher Constructor Description FlowPublisherFromReactive(Publisher<? extends T> reactivePublisher)
-
Uses of Publisher in org.reactivestreams.example.unicast
Classes in org.reactivestreams.example.unicast that implement Publisher Modifier and Type Class Description class
AsyncIterablePublisher<T>
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
InfiniteIncrementNumberPublisher
class
NumberIterablePublisher
class
RangePublisher
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 Publisher Modifier and Type Class Description class
IdentityProcessorVerification.TestSetup
class
SubscriberBlackboxVerification.BlackboxTestStage
class
SubscriberWhiteboxVerification.WhiteboxTestStage
static class
TestEnvironment.ManualPublisher<T>
Fields in org.reactivestreams.tck declared as Publisher Modifier and Type Field Description Publisher<T>
SubscriberBlackboxVerification.BlackboxTestStage. pub
Publisher<T>
SubscriberWhiteboxVerification.WhiteboxTestStage. pub
Methods in org.reactivestreams.tck that return Publisher Modifier and Type Method Description abstract Publisher<T>
IdentityProcessorVerification. createFailedPublisher()
By implementing this method, additional TCK tests concerning a "failed" publishers will be run.abstract Publisher<T>
PublisherVerification. createFailedPublisher()
By implementing this method, additional TCK tests concerning a "failed" publishers will be run.Publisher<T>
SubscriberBlackboxVerification.BlackboxTestStage. createHelperPublisher(long elements)
Publisher<T>
SubscriberWhiteboxVerification.WhiteboxTestStage. createHelperPublisher(long elements)
Publisher<T>
WithHelperPublisher. createHelperPublisher(long elements)
Helper method required for creating the Publisher to which the tested Subscriber will be subscribed and tested against.Publisher<T>
IdentityProcessorVerification. createPublisher(long elements)
abstract Publisher<T>
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 Publisher Modifier and Type Method Description <T> TestEnvironment.ManualSubscriber<T>
TestEnvironment. newBlackholeSubscriber(Publisher<T> pub)
<T> TestEnvironment.ManualSubscriber<T>
TestEnvironment. newManualSubscriber(Publisher<T> pub)
<T> TestEnvironment.ManualSubscriber<T>
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, java.lang.String message)
void
PublisherVerification.PublisherTestRun. run(Publisher<T> pub)
<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 Publisher Modifier and Type Method Description Publisher<T>
FlowPublisherVerification. createFailedPublisher()
Publisher<T>
IdentityFlowProcessorVerification. createFailedPublisher()
Publisher<T>
FlowPublisherVerification. createPublisher(long elements)
-
Uses of Publisher in org.reactivestreams.tck.flow.support
Classes in org.reactivestreams.tck.flow.support that implement Publisher Modifier and Type Class Description class
HelperPublisher<T>
class
InfiniteHelperPublisher<T>
-