Class ProxyServlet.ProxyInputStreamContentProvider

java.lang.Object

org.eclipse.jetty.client.util.InputStreamContentProvider

org.eclipse.jetty.proxy.ProxyServlet.ProxyInputStreamContentProvider

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<ByteBuffer>, ContentProvider, Callback, Invocable

Enclosing class:

ProxyServlet

protected class ProxyServlet.ProxyInputStreamContentProvider
extends InputStreamContentProvider

Nested Class Summary

Nested classes/interfaces inherited from interface Callback

Callback.Completable, Callback.Completing, Callback.Nested

Nested classes/interfaces inherited from interface ContentProvider

ContentProvider.Typed

Nested classes/interfaces inherited from interface Invocable

Invocable.InvocationType

Field Summary

Fields

Modifier and Type	Field	Description
private final Request	proxyRequest
private final javax.servlet.http.HttpServletRequest	request
private final javax.servlet.http.HttpServletResponse	response

Fields inherited from interface Callback

NOOP

Fields inherited from interface Invocable

__nonBlocking

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ProxyInputStreamContentProvider(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Request proxyRequest, InputStream input)

Method Summary

Modifier and Type	Method	Description
long	getLength()
protected ByteBuffer	onRead(byte[] buffer, int offset, int length)	Callback method invoked just after having read from the stream, but before returning the iteration element (a ByteBuffer to the caller.
protected void	onReadFailure(Throwable failure)	Callback method invoked when an exception is thrown while reading from the stream.
protected ByteBuffer	onRequestContent(javax.servlet.http.HttpServletRequest request, Request proxyRequest, byte[] buffer, int offset, int length)

Methods inherited from class InputStreamContentProvider

close, failed, iterator

Methods inherited from class Object

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

Methods inherited from interface Callback

succeeded

Methods inherited from interface ContentProvider

isReproducible

Methods inherited from interface Invocable

getInvocationType

Methods inherited from interface Iterable

forEach, spliterator

Field Details

response

private final javax.servlet.http.HttpServletResponse response

proxyRequest

private final Request proxyRequest

request

private final javax.servlet.http.HttpServletRequest request

Constructor Details

ProxyInputStreamContentProvider

protected ProxyInputStreamContentProvider(javax.servlet.http.HttpServletRequest request,
 javax.servlet.http.HttpServletResponse response,
 Request proxyRequest,
 InputStream input)

Method Details

getLength

public long getLength()

Specified by:

getLength in interface ContentProvider

Overrides:

getLength in class InputStreamContentProvider

Returns:

the content length, if known, or -1 if the content length is unknown

onRead

protected ByteBuffer onRead(byte[] buffer,
 int offset,
 int length)

Description copied from class: InputStreamContentProvider

Callback method invoked just after having read from the stream, but before returning the iteration element (a ByteBuffer to the caller.

Subclasses may override this method to copy the content read from the stream to another location (a file, or in memory if the content is known to fit).

Overrides:

onRead in class InputStreamContentProvider

Parameters:

buffer - the byte array containing the bytes read

offset - the offset from where bytes should be read

length - the length of the bytes read

Returns:

a ByteBuffer wrapping the byte array

onRequestContent

protected ByteBuffer onRequestContent(javax.servlet.http.HttpServletRequest request,
 Request proxyRequest,
 byte[] buffer,
 int offset,
 int length)

onReadFailure

protected void onReadFailure(Throwable failure)

Description copied from class: InputStreamContentProvider

Callback method invoked when an exception is thrown while reading from the stream.

Overrides:

onReadFailure in class InputStreamContentProvider

Parameters:

failure - the exception thrown while reading from the stream.