io.druid.java.util.http.client.response

Class SequenceInputStreamResponseHandler

java.lang.Object

io.druid.java.util.http.client.response.SequenceInputStreamResponseHandler

All Implemented Interfaces:

HttpResponseHandler<InputStream,InputStream>

public class SequenceInputStreamResponseHandler
extends Object
implements HttpResponseHandler<InputStream,InputStream>

A HTTP response handler which uses sequence input streams to create a final InputStream. Any particular instance is encouraged to overwrite a method and call the super if they need extra handling of the method parameters. This implementation uses a blocking queue to feed a SequenceInputStream that is terminated whenever the handler's Done method is called or a throwable is detected. The resulting InputStream will attempt to terminate normally, but on exception in HttpResponseHandler may end with an IOException upon read()

Constructor Summary

Constructors

Constructor and Description
SequenceInputStreamResponseHandler()

Method Summary

Modifier and Type	Method and Description
ClientResponse<InputStream>	done(ClientResponse<InputStream> clientResponse)
void	exceptionCaught(ClientResponse<InputStream> clientResponse, Throwable e)
long	getByteCount()
ClientResponse<InputStream>	handleChunk(ClientResponse<InputStream> clientResponse, org.jboss.netty.handler.codec.http.HttpChunk chunk)
ClientResponse<InputStream>	handleResponse(org.jboss.netty.handler.codec.http.HttpResponse response) Handles the initial HttpResponse object that comes back from Netty.

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceInputStreamResponseHandler

public SequenceInputStreamResponseHandler()

Method Detail

handleResponse

public ClientResponse<InputStream> handleResponse(org.jboss.netty.handler.codec.http.HttpResponse response)

Description copied from interface: HttpResponseHandler

Handles the initial HttpResponse object that comes back from Netty.

Specified by:

handleResponse in interface HttpResponseHandler<InputStream,InputStream>

Parameters:

response - - response from Netty

Returns:

handleChunk

public ClientResponse<InputStream> handleChunk(ClientResponse<InputStream> clientResponse,
                                               org.jboss.netty.handler.codec.http.HttpChunk chunk)

Specified by:

handleChunk in interface HttpResponseHandler<InputStream,InputStream>

done

public ClientResponse<InputStream> done(ClientResponse<InputStream> clientResponse)

Specified by:

done in interface HttpResponseHandler<InputStream,InputStream>

exceptionCaught

public void exceptionCaught(ClientResponse<InputStream> clientResponse,
                            Throwable e)

Specified by:

exceptionCaught in interface HttpResponseHandler<InputStream,InputStream>

getByteCount

public final long getByteCount()