com.linkedin.multipart

Class MultiPartMIMEInputStream

java.lang.Object

com.linkedin.multipart.MultiPartMIMEInputStream

All Implemented Interfaces:

MultiPartMIMEDataSourceWriter, com.linkedin.r2.message.stream.entitystream.Writer

public final class MultiPartMIMEInputStream
extends java.lang.Object
implements MultiPartMIMEDataSourceWriter

A wrapper around an InputStream to function as a data source to for a MultiPartMIMEWriter. This class uses the provided ExecutorService to perform blocking reads and respond to write requests asynchronously. This class will close the underlying input stream when either of these events happen: 1. The stream is finished being read. 2. There was an exception reading the stream, at which point the stream is closed and error() is called on the write handle. 3. The writer was aborted.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MultiPartMIMEInputStream.Builder Builder to create a new instance of a MultiPartMIMEInputStream that wraps the provided InputStream.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_ABORT_INPUT_STREAM_TIMEOUT
static int	DEFAULT_MAXIMUM_BLOCKING_DURATION
static int	DEFAULT_WRITE_CHUNK_SIZE

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.String>	dataSourceHeaders() Immediately return the headers need for this part.
void	onAbort(java.lang.Throwable e)
void	onInit(com.linkedin.r2.message.stream.entitystream.WriteHandle wh)
void	onWritePossible()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAXIMUM_BLOCKING_DURATION

public static final int DEFAULT_MAXIMUM_BLOCKING_DURATION

See Also:

Constant Field Values

DEFAULT_WRITE_CHUNK_SIZE

public static final int DEFAULT_WRITE_CHUNK_SIZE

See Also:

Constant Field Values

DEFAULT_ABORT_INPUT_STREAM_TIMEOUT

public static final int DEFAULT_ABORT_INPUT_STREAM_TIMEOUT

See Also:

Constant Field Values

Method Detail

onInit

public void onInit(com.linkedin.r2.message.stream.entitystream.WriteHandle wh)

Specified by:

onInit in interface com.linkedin.r2.message.stream.entitystream.Writer

onWritePossible

public void onWritePossible()

Specified by:

onWritePossible in interface com.linkedin.r2.message.stream.entitystream.Writer

onAbort

public void onAbort(java.lang.Throwable e)

Specified by:

onAbort in interface com.linkedin.r2.message.stream.entitystream.Writer

dataSourceHeaders

public java.util.Map<java.lang.String,java.lang.String> dataSourceHeaders()

Description copied from interface: MultiPartMIMEDataSourceWriter

Immediately return the headers need for this part. If no headers are provided, clients must return an empty map.

Specified by:

dataSourceHeaders in interface MultiPartMIMEDataSourceWriter

Returns:

a Map representing the headers for this data source.