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

Packages that use Flow.Publisher

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.common.reactive.valve	Reactive utilities for Helidon projects.
io.helidon.config	Provides interfaces and classes for loading and working with immutable, tree-structured configuration data.
io.helidon.config.etcd	Etcd configuration source.
io.helidon.config.spi	Configuration SPI that defines the behavior developers can implement to extend the config system.
io.helidon.media.common	Common classes for processing content with a specific MediaType.
io.helidon.media.jackson.common	Jackson media type support.
io.helidon.media.jsonb.common	JSON-B media type support.
io.helidon.media.jsonp.common	JSON-P media type support.
io.helidon.media.jsonp.server	This package contains JSON-P (javax.json) support for WebServer's Routing.
io.helidon.security	Security
io.helidon.webserver	Reactive web server API.

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

Subinterfaces of Flow.Publisher in io.helidon.common.http

Modifier and Type	Interface	Description
interface	Content	Represents an HTTP entity as a publisher of chunks with specific features.

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

Modifier and Type	Method	Description
default CompletionStage<? extends R>	Reader.apply(Flow.Publisher<DataChunk> publisher)	Transforms a publisher into a completion stage.
CompletionStage<? extends R>	Reader.apply(Flow.Publisher<DataChunk> publisher, Class<? super R> clazz)	Transforms a publisher into a completion stage.
default <T extends R> CompletionStage<? extends T>	Reader.applyAndCast(Flow.Publisher<DataChunk> publisher, Class<T> type)	Transforms a publisher into a completion stage.

Method parameters in io.helidon.common.http with type arguments of type Flow.Publisher

Modifier and Type	Method	Description
void	Content.registerFilter(Function<Flow.Publisher<DataChunk>,Flow.Publisher<DataChunk>> function)	Registers a filter that allows a control of the original publisher.
void	Content.registerFilter(Function<Flow.Publisher<DataChunk>,Flow.Publisher<DataChunk>> function)	Registers a filter that allows a control of the original publisher.

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

Subinterfaces of Flow.Publisher 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.
interface	Multi<T>	Multiple items publisher facility.
interface	Single<T>	Single item publisher utility.
interface	Subscribable<T>	Decorated publisher that allows subscribing to individual events with java functions.

Classes in io.helidon.common.reactive that implement Flow.Publisher

Modifier and Type	Class	Description
class	OriginThreadPublisher<T,U>	The OriginThreadPublisher's nature is to always run Flow.Subscriber.onNext(Object) on the very same thread as OriginThreadPublisher.submit(Object).
class	OutputStreamPublisher	Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.
class	SubmissionPublisher<T>	Deprecated. This class will be removed in the next major release.

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

Modifier and Type	Method	Description
static <T> Flow.Publisher<T>	ReactiveStreamsAdapter.publisherToFlow(Publisher<T> publisher)	Deprecated. Return a Flow.Publisher from a Publisher.

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

Modifier and Type	Method	Description
static <T> Multi<T>	Multi.from(Flow.Publisher<T> source)	Create a Multi instance wrapped around the given publisher.
static <T> Single<T>	Single.from(Flow.Publisher<T> source)	Create a Single instance that publishes the first and only item received from the given publisher.
static <T> reactor.core.publisher.Flux<T>	ReactiveStreamsAdapter.publisherFromFlow(Flow.Publisher<T> publisher)	Deprecated. Return a Publisher from a Flow.Publisher.

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

Modifier and Type	Method	Description
default <U> Multi<U>	Single.mapMany(Mapper<T,Flow.Publisher<U>> mapper)	Map this Single instance to a publisher using the given Mapper.

Uses of Flow.Publisher in io.helidon.common.reactive.valve

Methods in io.helidon.common.reactive.valve that return Flow.Publisher

Modifier and Type	Method	Description
default Flow.Publisher<T>	Valve.toPublisher()	Transforms this Valve into Flow.Publisher representation.

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

Modifier and Type	Method	Description
static <T> Valve<T>	Valves.from(Flow.Publisher<T> publisher)	Creates a Valve instance from provided Flow.Publisher.

Uses of Flow.Publisher in io.helidon.config

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

Modifier and Type	Method	Description
default Flow.Publisher<Config>	Config.changes()	Deprecated.
static <T> Flow.Publisher<T>	ConfigHelper.suspendablePublisher(Flow.Publisher<T> delegatePublisher, Runnable onFirstSubscriptionRequest, Runnable onLastSubscriptionCancel)	Creates a Flow.Publisher which wraps the provided one and also supports "active" and "suspended" states.

Methods in io.helidon.config with parameters of type Flow.Publisher

Modifier and Type	Method	Description
static <T> Flow.Publisher<T>	ConfigHelper.suspendablePublisher(Flow.Publisher<T> delegatePublisher, Runnable onFirstSubscriptionRequest, Runnable onLastSubscriptionCancel)	Creates a Flow.Publisher which wraps the provided one and also supports "active" and "suspended" states.

Uses of Flow.Publisher in io.helidon.config.etcd

Methods in io.helidon.config.etcd that return Flow.Publisher

Modifier and Type	Method	Description
Flow.Publisher<PollingStrategy.PollingEvent>	EtcdWatchPollingStrategy.ticks()

Uses of Flow.Publisher in io.helidon.config.spi

Methods in io.helidon.config.spi that return Flow.Publisher

Modifier and Type	Method	Description
Flow.Publisher<Optional<ConfigNode.ObjectNode>>	AbstractConfigSource.changes()	Returns a Flow.Publisher to which the caller can subscribe in order to receive change notifications.
Flow.Publisher<Optional<OverrideSource.OverrideData>>	AbstractOverrideSource.changes()
Flow.Publisher<Optional<T>>	Changeable.changes()	Deprecated.
default Flow.Publisher<Optional<T>>	Source.changes()	Deprecated.
Flow.Publisher<PollingStrategy.PollingEvent>	PollingStrategy.ticks()	Returns a Flow.Publisher which fires PollingStrategy.PollingEvents.

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

Classes in io.helidon.media.common that implement Flow.Publisher

Modifier and Type	Class	Description
class	ReadableByteChannelPublisher	Publish a channel content to a single subscriber.

Methods in io.helidon.media.common that return types with arguments of type Flow.Publisher

Modifier and Type	Method	Description
static Function<byte[],Flow.Publisher<DataChunk>>	ContentWriters.byteArrayWriter(boolean copy)	Returns a writer function for byte[].
static Function<ReadableByteChannel,Flow.Publisher<DataChunk>>	ContentWriters.byteChannelWriter()	Returns a writer function for ReadableByteChannel.
static Function<ReadableByteChannel,Flow.Publisher<DataChunk>>	ContentWriters.byteChannelWriter(RetrySchema retrySchema)	Returns a writer function for ReadableByteChannel.
static Function<CharBuffer,Flow.Publisher<DataChunk>>	ContentWriters.charBufferWriter(Charset charset)	Returns a writer function for CharBuffer using provided standard charset.
static Function<CharSequence,Flow.Publisher<DataChunk>>	ContentWriters.charSequenceWriter(Charset charset)	Returns a writer function for CharSequence using provided standard charset.

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

Modifier and Type	Method	Description
static Single<byte[]>	ContentReaders.readBytes(Flow.Publisher<DataChunk> chunks)	Collect the DataChunk of the given publisher into a single byte array.
static Single<String>	ContentReaders.readString(Flow.Publisher<DataChunk> chunks, Charset charset)	Convert the given publisher of DataChunk into a String.
static Single<String>	ContentReaders.readURLEncodedString(Flow.Publisher<DataChunk> chunks, Charset charset)	Convert the publisher of DataChunk into a String processed through URL decoding.

Constructors in io.helidon.media.common with parameters of type Flow.Publisher

Constructor	Description
DataChunkInputStream(Flow.Publisher<DataChunk> originalPublisher)	Stores publisher for later subscription.

Uses of Flow.Publisher in io.helidon.media.jackson.common

Methods in io.helidon.media.jackson.common that return types with arguments of type Flow.Publisher

Modifier and Type	Method	Description
static Function<Object,Flow.Publisher<DataChunk>>	JacksonProcessing.writer(ObjectMapper objectMapper, Charset charset)	Returns a function (writer) converting Objects to Publishers of DataChunks by using the supplied ObjectMapper.

Uses of Flow.Publisher in io.helidon.media.jsonb.common

Methods in io.helidon.media.jsonb.common that return types with arguments of type Flow.Publisher

Modifier and Type	Method	Description
static Function<Object,Flow.Publisher<DataChunk>>	JsonBinding.writer(Jsonb jsonb, Charset charset)	Returns a function (writer) converting Objects to Publishers of DataChunks by using the supplied Jsonb.

Uses of Flow.Publisher in io.helidon.media.jsonp.common

Methods in io.helidon.media.jsonp.common that return types with arguments of type Flow.Publisher

Modifier and Type	Method	Description
Function<JsonStructure,Flow.Publisher<DataChunk>>	JsonProcessing.writer()	Returns a function (writer) converting JsonStructure to the Publisher of DataChunks.
Function<JsonStructure,Flow.Publisher<DataChunk>>	JsonProcessing.writer(Charset charset)	Returns a function (writer) converting JsonStructure to the Publisher of DataChunks.

Uses of Flow.Publisher in io.helidon.media.jsonp.server

Methods in io.helidon.media.jsonp.server that return types with arguments of type Flow.Publisher

Modifier and Type	Method	Description
Function<JsonStructure,Flow.Publisher<DataChunk>>	JsonSupport.writer()	Returns a function (writer) converting JsonStructure to the Publisher of DataChunks.
Function<JsonStructure,Flow.Publisher<DataChunk>>	JsonSupport.writer(Charset charset)	Returns a function (writer) converting JsonStructure to the Publisher of DataChunks.

Uses of Flow.Publisher in io.helidon.security

Method parameters in io.helidon.security with type arguments of type Flow.Publisher

Modifier and Type	Method	Description
void	Entity.filter(Function<Flow.Publisher<ByteBuffer>,Flow.Publisher<ByteBuffer>> filterFunction)	Call this method if your security provider needs access to entity bytes.
void	Entity.filter(Function<Flow.Publisher<ByteBuffer>,Flow.Publisher<ByteBuffer>> filterFunction)	Call this method if your security provider needs access to entity bytes.

Uses of Flow.Publisher in io.helidon.webserver

Methods in io.helidon.webserver that return Flow.Publisher

Modifier and Type	Method	Description
Flow.Publisher<DataChunk>	BareRequest.bodyPublisher()	Gets the Flow Publisher that allows a subscription for request body chunks.

Methods in io.helidon.webserver with parameters of type Flow.Publisher

Modifier and Type	Method	Description
CompletionStage<ServerResponse>	ServerResponse.send(Flow.Publisher<DataChunk> content)	Send a message as is without any other marshalling.

Method parameters in io.helidon.webserver with type arguments of type Flow.Publisher

Modifier and Type	Method	Description
ServerResponse	ServerResponse.registerFilter(Function<Flow.Publisher<DataChunk>,Flow.Publisher<DataChunk>> function)	Registers a provider of the new response content publisher - typically a filter.
ServerResponse	ServerResponse.registerFilter(Function<Flow.Publisher<DataChunk>,Flow.Publisher<DataChunk>> function)	Registers a provider of the new response content publisher - typically a filter.
<T> ServerResponse	ServerResponse.registerWriter(Class<T> type, MediaType contentType, Function<? extends T,Flow.Publisher<DataChunk>> function)	Registers a content writer for a given type and media type.
<T> ServerResponse	ServerResponse.registerWriter(Class<T> type, Function<T,Flow.Publisher<DataChunk>> function)	Registers a content writer for a given type.
<T> ServerResponse	ServerResponse.registerWriter(Predicate<?> accept, MediaType contentType, Function<T,Flow.Publisher<DataChunk>> function)	Registers a content writer for all accepted contents.
<T> ServerResponse	ServerResponse.registerWriter(Predicate<?> accept, Function<T,Flow.Publisher<DataChunk>> function)	Registers a content writer for all accepted contents.