public Mono<CosmosDatabaseResponse> createDatabase(
            final String databaseName, final ThroughputProperties throughputProperties) {
        CosmosDbUtils.validateIfParameterIsNotEmpty(databaseName, PARAM_DATABASE_NAME);

        return client.createDatabaseIfNotExists(databaseName, throughputProperties);
    }
@Test
    void testCreateDatabase() {
        final CosmosAsyncClientWrapper client = mock(CosmosAsyncClientWrapper.class);
        when(client.createDatabaseIfNotExists(any(), any())).thenReturn(Mono.just(mock(CosmosDatabaseResponse.class)));

        final CosmosDbClientOperations operations = CosmosDbClientOperations.withClient(client);

        CosmosDbTestUtils.assertIllegalArgumentException(() -> operations.createDatabase(null, null));
        CosmosDbTestUtils.assertIllegalArgumentException(() -> operations.createDatabase("", null));

        assertNotNull(operations.createDatabase("test", null).block());
    }