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

Class HttpTransportClient

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

com.microsoft.azure.cosmosdb.internal.directconnectivity.HttpTransportClient

All Implemented Interfaces:

AutoCloseable

public class HttpTransportClient
extends TransportClient

Constructor Summary

Constructors

Constructor	Description
HttpTransportClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs, int requestTimeout, com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent)

Method Summary

Modifier and Type	Method	Description
void	close()
rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse>	invokeStoreAsync(com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri physicalAddressUri, ResourceOperation resourceOperation, com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)

Methods inherited from class com.microsoft.azure.cosmosdb.internal.directconnectivity.TransportClient

invokeResourceOperationAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpTransportClient

public HttpTransportClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs,
                           int requestTimeout,
                           com.microsoft.azure.cosmosdb.internal.UserAgentContainer userAgent)

Method Detail

close

public void close()

invokeStoreAsync

public rx.Single<com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreResponse> invokeStoreAsync(com.microsoft.azure.cosmosdb.internal.directconnectivity.Uri physicalAddressUri,
                                                                                                          ResourceOperation resourceOperation,
                                                                                                          com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request)

Specified by:

invokeStoreAsync in class TransportClient