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 SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsubscribe(Subscriber<? super T> s)RequestPublisherto start streaming data.
 
- 
- 
- 
Method Detail- 
subscribevoid 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- the- Subscriberthat will consume signals from this- Publisher
 
 
- 
 
-