com.basho.riak.client.http.response
Interface StreamHandler

public interface StreamHandler

Used with RiakClient.stream() to process the HTTP responses for fetch requests as a stream.

Method Summary

boolean

process(String bucket, String key, int status, Map<String,String> headers, InputStream in, org.apache.http.HttpResponse httpMethod) Process the HTTP response whose value is given as a stream.

Method Detail

process

boolean process(String bucket,
                String key,
                int status,
                Map<String,String> headers,
                InputStream in,
                org.apache.http.HttpResponse httpMethod)

Process the HTTP response whose value is given as a stream.

Parameters:

bucket - The object's bucket

key - The object's key

status - The HTTP status code returned for the request

headers - The HTTP headers returned in the response

in - InputStream of the object's value (body)

httpMethod - The original HttpRequestBase used to make the request. Its connection is still open and will be closed by the caller on return.

Returns:

true if the object was processed; false otherwise