com.microsoft.azure.cosmosdb.internal.directconnectivity

Interface IStoreClient

All Known Implementing Classes:

StoreClient

public interface IStoreClient

Method Summary

Modifier and Type	Method and Description
default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse>	processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)
default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse>	processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)
default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse>	processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy)
rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse>	processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy, rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)

Method Detail

processMessageAsync

rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse> processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                  com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy,
                                                                                                  rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)

processMessageAsync

default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse> processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                          rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)

processMessageAsync

default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse> processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                          com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy)

processMessageAsync

default rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse> processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)