Package io.servicetalk.http.router.jersey.internal

Class BufferPublisherInputStream

java.lang.Object

java.io.InputStream

io.servicetalk.http.router.jersey.internal.BufferPublisherInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class BufferPublisherInputStream
extends InputStream

An InputStream built around a Publisher<Buffer>, which can either be read OIO style or provide its wrapped Publisher. This allows us to provide JAX-RS with an InputStream and also short-circuit its usage when our code can directly deal with the Publisher<Buffer> it wraps.

Not threadsafe and intended to be used internally only, where no concurrency occurs between read(), read(byte[], int, int) and bufferPublisher().

Constructor Summary

Constructors

Constructor	Description
BufferPublisherInputStream(Publisher<Buffer> publisher, int queueCapacity)	Creates a new BufferPublisherInputStream instance.

Method Summary

Modifier and Type	Method	Description
static <T> T	handleEntityStream(InputStream entityStream, BufferAllocator allocator, BiFunction<Publisher<Buffer>,BufferAllocator,T> bufferPublisherHandler, BiFunction<InputStream,BufferAllocator,T> inputStreamHandler)	Helper method for dealing with a request entity InputStream that is potentially a BufferPublisherInputStream.
void	offloadSourcePublisher(HttpExecutionStrategy executionStrategy, Executor executor)	Offload operations on the wrapped Publisher<Buffer> to the designated executor.
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

BufferPublisherInputStream

public BufferPublisherInputStream(Publisher<Buffer> publisher,
 int queueCapacity)

Creates a new BufferPublisherInputStream instance.

Parameters:

publisher - the Publisher<Buffer> to read from.

queueCapacity - the capacity hint for the intermediary queue that stores items.

Method Details

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

offloadSourcePublisher

public void offloadSourcePublisher(HttpExecutionStrategy executionStrategy,
 Executor executor)

Offload operations on the wrapped Publisher<Buffer> to the designated executor.

Parameters:

executionStrategy - the HttpExecutionStrategy to use.

executor - the Executor to use with the HttpExecutionStrategy.

handleEntityStream

public static <T> T handleEntityStream(InputStream entityStream,
 BufferAllocator allocator,
 BiFunction<Publisher<Buffer>,BufferAllocator,T> bufferPublisherHandler,
 BiFunction<InputStream,BufferAllocator,T> inputStreamHandler)

Helper method for dealing with a request entity InputStream that is potentially a BufferPublisherInputStream.

Type Parameters:

T - the type of data returned by the BiFunctions.

Parameters:

entityStream - the request entity InputStream

allocator - the BufferAllocator to use

bufferPublisherHandler - a BiFunction that is called in case the entity InputStream is a BufferPublisherInputStream

inputStreamHandler - a BiFunction that is called in case the entity InputStream is not a BufferPublisherInputStream

Returns:

the data returned by one of the BiFunction.