Package com.netflix.hystrix

Interface HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>

Enclosing class:

HystrixCollapser<BatchReturnType,ResponseType,RequestArgumentType>

public static interface HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>

A request argument RequestArgumentType that was collapsed for batch processing and needs a response ResponseType set on it by the executeBatch implementation.

Method Summary

Modifier and Type	Method and Description
void	emitResponse(ResponseType response) When invoked, any Observer will be OnNexted this value
RequestArgumentType	getArgument() The request argument passed into the HystrixCollapser instance constructor which was then collapsed.
void	setComplete() When set, any Observer will have an OnCompleted emitted.
void	setException(java.lang.Exception exception) When set, any Observer will be OnErrored this exception
void	setResponse(ResponseType response) This corresponds in a OnNext(Response); OnCompleted pair of emissions.

Method Detail

getArgument

RequestArgumentType getArgument()

The request argument passed into the HystrixCollapser instance constructor which was then collapsed.

Returns:

RequestArgumentType

setResponse

void setResponse(ResponseType response)

This corresponds in a OnNext(Response); OnCompleted pair of emissions. It represents a single-value usecase.

Parameters:

response - ResponseType

Throws:

java.lang.IllegalStateException - if called more than once or after setException/setComplete.

emitResponse

void emitResponse(ResponseType response)

When invoked, any Observer will be OnNexted this value

Parameters:

response -

Throws:

java.lang.IllegalStateException - if called after setException/setResponse/setComplete.

setException

void setException(java.lang.Exception exception)

When set, any Observer will be OnErrored this exception

Parameters:

exception - exception to set on response

Throws:

java.lang.IllegalStateException - if called more than once or after setResponse/setComplete.

setComplete

void setComplete()

When set, any Observer will have an OnCompleted emitted. The intent is to use if after a series of emitResponses Note that, unlike the other 3 methods above, this method does not throw an IllegalStateException. This allows Hystrix-core to unilaterally call it without knowing the internal state.