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>	A Processor represents a processing stage—which is both a Subscriber and a Publisher 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 the Publisher 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>