adapt(org.reactivestreams.Publisher<T> toAdapt)
Creates a new publisher that emits trailing events provided by trailingDataSupplier in addition to the published events.
Buffers the events into lists of the given buffer size.
Add a callback that will be invoked after this publisher invokes Subscription.cancel().
Add a callback that will be invoked after this publisher invokes Subscriber.onComplete().
Add a callback that will be invoked after this publisher invokes Subscriber.onError(Throwable).
Filters published events to just those that are instances of the given class.
Filters published events to just those that match the given predicate.
Performs a mapping on the published events and creates a new publisher that emits the mapped events one by one.
Limit the number of published events and cancel the subscription after that limit has been reached.
Perform a mapping on the published events.
Subscribes to the publisher with the given
Consumer
.
Methods inherited from interface org.reactivestreams.Publishersubscribe
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4