Package com.microsoft.azure.cosmosdb.internal.directconnectivity

Class ConsistencyWriter

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.ConsistencyWriter

public class ConsistencyWriter
extends Object

Constructor Summary

Constructors

Constructor	Description
ConsistencyWriter(AddressSelector addressSelector, com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer, TransportClient transportClient, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider, GatewayServiceConfigurationReader serviceConfigReader, boolean useMultipleWriteLocations)

Method Summary

Modifier and Type	Method	Description
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>	writeAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity, com.microsoft.azure.cosmosdb.internal.directconnectivity.TimeoutHelper timeout, boolean forceRefresh)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsistencyWriter

public ConsistencyWriter(AddressSelector addressSelector,
                         com.microsoft.azure.cosmosdb.ISessionContainer sessionContainer,
                         TransportClient transportClient,
                         com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider authorizationTokenProvider,
                         GatewayServiceConfigurationReader serviceConfigReader,
                         boolean useMultipleWriteLocations)

Method Detail

writeAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse> writeAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest entity,
                                                                                                    com.microsoft.azure.cosmosdb.internal.directconnectivity.TimeoutHelper timeout,
                                                                                                    boolean forceRefresh)