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

static final class FlowAdapters.ReactivePublisherFromFlow<T>
extends Object
implements Publisher<T>

Reactive Streams Publisher that wraps a Flow Publisher.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Flow.Publisher<? extends T>	flow

Constructor Summary

Constructors

Constructor	Description
ReactivePublisherFromFlow(Flow.Publisher<? extends T> flowPublisher)

Method Summary

Modifier and Type	Method	Description
void	subscribe(Subscriber<? super T> reactive)	Request Publisher to start streaming data.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

flow

final Flow.Publisher<? extends T> flow

Constructor Details

ReactivePublisherFromFlow

public ReactivePublisherFromFlow(Flow.Publisher<? extends T> flowPublisher)

Method Details

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