public <T> Flux<T> queryItems(
            final String query, final CosmosQueryRequestOptions queryRequestOptions, final Class<T> itemType) {
        CosmosDbUtils.validateIfParameterIsNotEmpty(query, PARAM_QUERY);
        CosmosDbUtils.validateIfParameterIsNotEmpty(itemType, PARAM_ITEM_TYPE);

        return container
                .flatMapMany(container -> CosmosDbUtils.convertCosmosPagedFluxToFluxResults(
                        container.queryItems(query, queryRequestOptions, itemType)));
    }
@Test
    void queryItems() {
        final CosmosDbContainerOperations operations
                = new CosmosDbContainerOperations(Mono.just(mock(CosmosAsyncContainer.class)));

        CosmosDbTestUtils.assertIllegalArgumentException(() -> operations.queryItems(null, null, null));
        CosmosDbTestUtils.assertIllegalArgumentException(() -> operations.queryItems(null, null, Object.class));
        CosmosDbTestUtils.assertIllegalArgumentException(() -> operations.queryItems("", null, Object.class));
    }