Share via

com.microsoft.azure.cosmosdb.rx

  • Reference

This package provides Rx interfaces for interacting with Azure Cosmos DB.

Classes

AsyncDocumentClient.Builder

Helper class to build AsyncDocumentClient instances as logical representation of the Azure Cosmos DB database service.


    ConnectionPolicy connectionPolicy = new ConnectionPolicy();

    connectionPolicy.setConnectionMode(ConnectionMode.Direct);

    AsyncDocumentClient client = new AsyncDocumentClient.Builder()

            .withServiceEndpoint(serviceEndpoint)

            .withMasterKeyOrResourceToken(masterKey)

            .withConnectionPolicy(connectionPolicy)

            .withConsistencyLevel(ConsistencyLevel.Session)

            .build();

Interfaces

AsyncDocumentClient

Provides a client-side logical representation of the Azure Cosmos DB database service. This async client is used to configure and execute requests against the service.

AsyncDocumentClient async APIs return rxJava'sObservable 

</code> , and so you can use rxJava <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> functionality. <b>The async <xref uid="" data-throw-if-not-resolved="false" data-raw-source="Observable"></xref> based APIs perform the requested operation only after subscription.</b></p>

The service client encapsulates the endpoint and credentials used to access the Cosmos DB service.

To instantiate you can use the AsyncDocumentClient.Builder

ConnectionPolicy connectionPolicy = new ConnectionPolicy();

connectionPolicy.setConnectionMode(ConnectionMode.Direct);

AsyncDocumentClient client = new AsyncDocumentClient.Builder()

        .withServiceEndpoint(serviceEndpoint)

        .withMasterKeyOrResourceToken(masterKey)

        .withConnectionPolicy(connectionPolicy)

        .withConsistencyLevel(ConsistencyLevel.Session)

        .build();

</code></pre></p>