Module io.helidon.media.common

Package io.helidon.media.common

Class ReadableByteChannelPublisher

java.lang.Object

io.helidon.media.common.ReadableByteChannelPublisher

All Implemented Interfaces:

Flow.Publisher<DataChunk>

@Deprecated(since="2.0.0",
            forRemoval=true)
public class ReadableByteChannelPublisher
extends Object
implements Flow.Publisher<DataChunk>

Deprecated, for removal: This API element is subject to removal in a future version.

Will be removed. Please use IoMulti.multiFromByteChannel(java.nio.channels.ReadableByteChannel) instead

Publish a channel content to a single subscriber. If channel doesn't offer data, then it is requested again after some period defined be retry schema.

Only first subscriber is accepted.

Constructor Summary

Constructors

Constructor	Description
ReadableByteChannelPublisher(ReadableByteChannel channel, RetrySchema retrySchema)	Deprecated, for removal: This API element is subject to removal in a future version. please use IoMulti.multiFromByteChannel(java.nio.channels.ReadableByteChannel)

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super DataChunk> subscriberParam)	Deprecated, for removal: This API element is subject to removal in a future version.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadableByteChannelPublisher

@Deprecated(since="2.0.0",
            forRemoval=true)
public ReadableByteChannelPublisher(ReadableByteChannel channel,
                                    RetrySchema retrySchema)

Deprecated, for removal: This API element is subject to removal in a future version.

please use IoMulti.multiFromByteChannel(java.nio.channels.ReadableByteChannel)

Creates new instance.

Parameters:

channel - a channel to read and publish

retrySchema - a retry schema functional interface used in case, that channel read retrieved zero bytes.

Method Detail

subscribe

public void subscribe(Flow.Subscriber<? super DataChunk> subscriberParam)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

subscribe in interface Flow.Publisher<DataChunk>