Uses of Interface
io.helidon.common.reactive.Flow.Subscriber

Packages that use Flow.Subscriber

Package	Description
io.helidon.common.http	HTTP APIs and implementations usable by both server and client side of the HTTP story.
io.helidon.common.reactive	Common reactive library for Helidon projects.
io.helidon.config	Provides interfaces and classes for loading and working with immutable, tree-structured configuration data.
io.helidon.media.common	Common classes for processing content with a specific MediaType.
io.helidon.webserver	Reactive web server API.

Uses of Flow.Subscriber in io.helidon.common.http

Methods in io.helidon.common.http with parameters of type Flow.Subscriber

Modifier and Type	Method	Description
void	Content.subscribe(Flow.Subscriber<? super DataChunk> subscriber)	If possible, adds the given Subscriber to this publisher.

Uses of Flow.Subscriber in io.helidon.common.reactive

Subinterfaces of Flow.Subscriber in io.helidon.common.reactive

Modifier and Type	Interface	Description
static interface	Flow.Processor<T,R>	A component that acts as both a Subscriber and Publisher.

Methods in io.helidon.common.reactive that return Flow.Subscriber

Modifier and Type	Method	Description
Flow.Subscriber<? super T>	SingleSubscriberHolder.get()	Get the stored subscriber.
static <T> Flow.Subscriber<T>	ReactiveStreamsAdapter.subscriberToFlow(Subscriber<T> subscriber)	Deprecated. Return a Flow.Subscriber from a Subscriber.

Methods in io.helidon.common.reactive with parameters of type Flow.Subscriber

Modifier and Type	Method	Description
boolean	SingleSubscriberHolder.register(Flow.Subscriber<? super T> subscriber)	Register a new subscriber.
void	Flow.Publisher.subscribe(Flow.Subscriber<? super T> subscriber)	Adds the given Subscriber if possible.
void	OriginThreadPublisher.subscribe(Flow.Subscriber<? super T> originalSubscriber)
void	OutputStreamPublisher.subscribe(Flow.Subscriber<? super ByteBuffer> subscriberParam)
void	SubmissionPublisher.subscribe(Flow.Subscriber<? super T> subscriber)	Deprecated. Adds the given Subscriber.
static <T> Subscriber<T>	ReactiveStreamsAdapter.subscriberFromFlow(Flow.Subscriber<T> subscriber)	Deprecated. Return a Subscriber from a Flow.Subscriber.

Method parameters in io.helidon.common.reactive with type arguments of type Flow.Subscriber

Modifier and Type	Method	Description
void	SingleSubscriberHolder.close(Consumer<Flow.Subscriber<? super T>> completionHandler)	Mark the subscriber holder as closed.
void	SubmissionPublisher.offer(T item, BiPredicate<Flow.Subscriber<? super T>,? super T> onDrop)	Deprecated. Publishes the given item to each current subscriber.

Uses of Flow.Subscriber in io.helidon.config

Methods in io.helidon.config that return Flow.Subscriber

Modifier and Type	Method	Description
static <T> Flow.Subscriber<T>	ConfigHelper.subscriber(Function<T,Boolean> onNextFunction)	Creates a Flow.Subscriber that will delegate onNext(Object) to the specified onNextFunction function.

Uses of Flow.Subscriber in io.helidon.media.common

Methods in io.helidon.media.common with parameters of type Flow.Subscriber

Modifier and Type	Method	Description
void	ReadableByteChannelPublisher.subscribe(Flow.Subscriber<? super DataChunk> subscriberParam)

Uses of Flow.Subscriber in io.helidon.webserver

Subinterfaces of Flow.Subscriber in io.helidon.webserver

Modifier and Type	Interface	Description
interface	BareResponse	Bare (minimal) representation of HTTP Response.