reactive-streams 1.0.4 · org.reactivestreams.Publisher

A Publisher is a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from its Subscriber(s).

A Publisher can serve multiple Subscribers subscribed Publisher#subscribe(Subscriber) dynamically at various points in time.

Method Summary

Modifier and Type	Method and Description
public void	subscribe(Subscriber<? super T> the `Subscriber` that will consume signals from this `Publisher` s) Request `Publisher` to start streaming data.

Method Detail

subscribe back to summary

subscribe	back to summary
public void subscribe(Subscriber<? super T> s) Request `Publisher` to start streaming data. This is a "factory method" and can be called multiple times, each time starting a new `Subscription`. Each `Subscription` will work for only a single `Subscriber`. A `Subscriber` should only subscribe once to a single `Publisher`. If the `Publisher` rejects the subscription attempt or otherwise fails it will signal the error via `Subscriber#onError(Throwable)`. Parameters s:Subscriber<? super T> the `Subscriber` that will consume signals from this `Publisher`

public void subscribe(Subscriber<? super T> s)

Request Publisher to start streaming data.

This is a "factory method" and can be called multiple times, each time starting a new Subscription.

Each Subscription will work for only a single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber#onError(Throwable).

Parameters

s:Subscriber<? super T>: the Subscriber that will consume signals from this Publisher

public Interface Publisher<T>

Method Summary

Method Detail