com.facebook.buck.slb

Class HybridThriftResponseHandler<ThriftResponse extends org.apache.thrift.TBase<?,?>>

java.lang.Object

com.facebook.buck.slb.HybridThriftResponseHandler<ThriftResponse>

public abstract class HybridThriftResponseHandler<ThriftResponse extends org.apache.thrift.TBase<?,?>>
extends Object

Control struct to receive a hybrid thrift response.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HybridThriftResponseHandler(ThriftResponse emptyResponse)

Method Summary

Modifier and Type	Method and Description
static <ThriftResponse extends org.apache.thrift.TBase<?,?>> HybridThriftResponseHandler<ThriftResponse>	createNoPayloadHandler(ThriftResponse response) Encodes a response without out-of-band payloads.
static <ThriftResponse extends org.apache.thrift.TBase<?,?>> HybridThriftResponseHandler<ThriftResponse>	createNoPayloadHandler(ThriftResponse response, ThrowingConsumer<ThriftResponse,IOException> validator) Encodes a response without out-of-band payloads.
abstract long	getPayloadSizeBytes(int index) Size bytes of the nth payload.
ThriftResponse	getResponse() The thrift response.
abstract OutputStream	getStreamForPayload(int index) Where to write the nth payload bytes to.
abstract int	getTotalPayloads() Total number of payloads expected for the current thrift response.
void	onResponseParsed() Called as soon as the thrift metadata section of the response is parsed.

Methods inherited from class java.lang.Object

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

Constructor Detail

HybridThriftResponseHandler

protected HybridThriftResponseHandler(ThriftResponse emptyResponse)

Method Detail

createNoPayloadHandler

public static <ThriftResponse extends org.apache.thrift.TBase<?,?>> HybridThriftResponseHandler<ThriftResponse> createNoPayloadHandler(ThriftResponse response)

Encodes a response without out-of-band payloads.

createNoPayloadHandler

public static <ThriftResponse extends org.apache.thrift.TBase<?,?>> HybridThriftResponseHandler<ThriftResponse> createNoPayloadHandler(ThriftResponse response,
                                                                                                                                       ThrowingConsumer<ThriftResponse,IOException> validator)

Encodes a response without out-of-band payloads.

getResponse

public ThriftResponse getResponse()

The thrift response.

onResponseParsed

public void onResponseParsed()
                      throws IOException

Called as soon as the thrift metadata section of the response is parsed.

Throws:

IOException

getTotalPayloads

public abstract int getTotalPayloads()

Total number of payloads expected for the current thrift response.

getPayloadSizeBytes

public abstract long getPayloadSizeBytes(int index)

Size bytes of the nth payload. Must be positive.

getStreamForPayload

public abstract OutputStream getStreamForPayload(int index)

Where to write the nth payload bytes to.