FlowAdapters.ReactivePublisherFromFlow

java.lang.Object
- org.reactivestreams.FlowAdapters.ReactivePublisherFromFlow<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Publisher<T>

Enclosing class:

FlowAdapters
```
static final class FlowAdapters.ReactivePublisherFromFlow<T>
extends java.lang.Object
implements Publisher<T>
```
Reactive Streams Publisher that wraps a Flow Publisher.

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  (package private) java.util.concurrent.Flow.Publisher<? extends T> flow
- Constructor Summary
  
  Constructors
  Constructor Description
  
  ReactivePublisherFromFlow(java.util.concurrent.Flow.Publisher<? extends T> flowPublisher)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void subscribe(Subscriber<? super T> reactive)
  Request Publisher to start streaming data.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - flow
```
final java.util.concurrent.Flow.Publisher<? extends T> flow
```
- Constructor Detail
  - ReactivePublisherFromFlow
```
public ReactivePublisherFromFlow(java.util.concurrent.Flow.Publisher<? extends T> flowPublisher)
```
- Method Detail
  - subscribe
```
public void subscribe(Subscriber<? super T> reactive)
```
    Description copied from interface: Publisher
    
    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).
    
    Specified by:
    
    subscribe in interface Publisher<T>
    
    Parameters:
    
    reactive - the Subscriber that will consume signals from this Publisher