com.couchbase.client.java.view

Class ViewRetryHandler

java.lang.Object

com.couchbase.client.java.view.ViewRetryHandler

public class ViewRetryHandler
extends Object

Generic View retry handler based on response code and value inspection.

Since:

2.0.2

Constructor Summary

Constructors

Constructor and Description
ViewRetryHandler()

Method Summary

Modifier and Type	Method and Description
static Observable<com.couchbase.client.core.message.view.ViewQueryResponse>	retryOnCondition(Observable<com.couchbase.client.core.message.view.ViewQueryResponse> input) Takes a ViewQueryResponse, verifies their status based on fixed criteria and resubscribes if needed.

Methods inherited from class java.lang.Object

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

Constructor Detail

ViewRetryHandler

public ViewRetryHandler()

Method Detail

retryOnCondition

public static Observable<com.couchbase.client.core.message.view.ViewQueryResponse> retryOnCondition(Observable<com.couchbase.client.core.message.view.ViewQueryResponse> input)

Takes a ViewQueryResponse, verifies their status based on fixed criteria and resubscribes if needed.

If it needs to be retried, the resubscription will happen after 10 milliseconds to give the underlying code some time to recover.

Parameters:

input - the original response.

Returns:

the good response which can be parsed, or a failing observable.