public Flux<CosmosDatabaseProperties> queryDatabases(
            final String query, final CosmosQueryRequestOptions queryRequestOptions) {
        CosmosDbUtils.validateIfParameterIsNotEmpty(query, "query");

        return CosmosDbUtils.convertCosmosPagedFluxToFluxResults(client.queryDatabases(query, queryRequestOptions));
    }
@Test
    void testQueryDatabases() {
        final CosmosAsyncClientWrapper client = mock(CosmosAsyncClientWrapper.class);
        final CosmosAsyncDatabase database = mock(CosmosAsyncDatabase.class);

        when(client.getDatabase("test")).thenReturn(database);

        final CosmosDbClientOperations operations = CosmosDbClientOperations.withClient(client);

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