Package org.reactivestreams
Class FlowAdapters.ReactivePublisherFromFlow<T>
java.lang.Object
org.reactivestreams.FlowAdapters.ReactivePublisherFromFlow<T>
- Type Parameters:
T
- the element type
- All Implemented Interfaces:
Publisher<T>
- Enclosing class:
FlowAdapters
Reactive Streams Publisher that wraps a Flow Publisher.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
subscribe
(Subscriber<? super T> reactive) RequestPublisher
to start streaming data.
-
Field Details
-
flow
-
-
Constructor Details
-
ReactivePublisherFromFlow
-
-
Method Details
-
subscribe
Description copied from interface:Publisher
RequestPublisher
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 singleSubscriber
.A
Subscriber
should only subscribe once to a singlePublisher
.If the
Publisher
rejects the subscription attempt or otherwise fails it will signal the error viaSubscriber.onError(Throwable)
.- Specified by:
subscribe
in interfacePublisher<T>
- Parameters:
reactive
- theSubscriber
that will consume signals from thisPublisher
-