com.linkedin.multipart

Class MultiPartMIMEInputStream.Builder

java.lang.Object

com.linkedin.multipart.MultiPartMIMEInputStream.Builder

Enclosing class:

MultiPartMIMEInputStream

public static class MultiPartMIMEInputStream.Builder
extends java.lang.Object

Builder to create a new instance of a MultiPartMIMEInputStream that wraps the provided InputStream.

Constructor Summary

Constructors

Constructor and Description
Builder(java.io.InputStream inputStream, java.util.concurrent.ExecutorService executorService, java.util.Map<java.lang.String,java.lang.String> headers) Construct the builder to eventually build a MultiPartMIMEInputStream.

Method Summary

Modifier and Type	Method and Description
MultiPartMIMEInputStream	build() Build and return the MultiPartMIMEInputStream.
MultiPartMIMEInputStream.Builder	withDefaultAbortInputStreamTimeout(int abortTimeout) The maximum amount of time to wait, in milliseconds, that a request to abort has to wait for any outstanding read (and therefore write) operations to finish.
MultiPartMIMEInputStream.Builder	withMaximumBlockingTime(int maximumBlockingTime) The maximum amount of time to wait, in milliseconds, on a synchronous read from the underlying input stream.
MultiPartMIMEInputStream.Builder	withWriteChunkSize(int writeChunkSize) The number of bytes to read from the input stream in order to fulfill write request.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(java.io.InputStream inputStream,
               java.util.concurrent.ExecutorService executorService,
               java.util.Map<java.lang.String,java.lang.String> headers)

Construct the builder to eventually build a MultiPartMIMEInputStream.

Parameters:

inputStream - the input stream to wrap.

executorService - the thread pool to run jobs to read.

headers - the headers representing this part.

Method Detail

withMaximumBlockingTime

public MultiPartMIMEInputStream.Builder withMaximumBlockingTime(int maximumBlockingTime)

The maximum amount of time to wait, in milliseconds, on a synchronous read from the underlying input stream.

Parameters:

maximumBlockingTime -

withWriteChunkSize

public MultiPartMIMEInputStream.Builder withWriteChunkSize(int writeChunkSize)

The number of bytes to read from the input stream in order to fulfill write request.

Parameters:

writeChunkSize -

withDefaultAbortInputStreamTimeout

public MultiPartMIMEInputStream.Builder withDefaultAbortInputStreamTimeout(int abortTimeout)

The maximum amount of time to wait, in milliseconds, that a request to abort has to wait for any outstanding read (and therefore write) operations to finish.

Parameters:

abortTimeout -

build

public MultiPartMIMEInputStream build()

Build and return the MultiPartMIMEInputStream.