Package org.reactivestreams
Interface Publisher<T>
-
- Type Parameters:
T- the type of element signaled
- All Known Subinterfaces:
Processor<T,R>
public interface Publisher<T>
APublisheris a provider of a potentially unbounded number of sequenced elements, publishing them according to the demand received from itsSubscriber(s).A
Publishercan serve multipleSubscribers subscribedsubscribe(Subscriber)dynamically at various points in time.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsubscribe(Subscriber<? super T> s)RequestPublisherto start streaming data.
-
-
-
Method Detail
-
subscribe
void subscribe(Subscriber<? super T> s)
RequestPublisherto start streaming data.This is a "factory method" and can be called multiple times, each time starting a new
Subscription.Each
Subscriptionwill work for only a singleSubscriber.A
Subscribershould only subscribe once to a singlePublisher.If the
Publisherrejects the subscription attempt or otherwise fails it will signal the error viaSubscriber.onError(Throwable).- Parameters:
s- theSubscriberthat will consume signals from thisPublisher
-
-