ilist.h

/*
 * Copyright (c) 2008-2022, Hazelcast, Inc. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#pragma once
 
#include "hazelcast/client/impl/ItemEventHandler.h"
#include "hazelcast/client/proxy/IListImpl.h"
#include "hazelcast/client/protocol/codec/codecs.h"
 
namespace hazelcast {
namespace client {
class ilist : public proxy::IListImpl
{
    friend class spi::ProxyManager;
 
public:
    static constexpr const char* SERVICE_NAME = "hz:impl:listService";
 
    boost::future<boost::uuids::uuid> add_item_listener(
      item_listener&& listener,
      bool include_value)
    {
        std::unique_ptr<
          impl::item_event_handler<protocol::codec::list_addlistener_handler>>
          itemEventHandler(new impl::item_event_handler<
                           protocol::codec::list_addlistener_handler>(
            get_name(),
            get_context().get_client_cluster_service(),
            get_context().get_serialization_service(),
            std::move(listener),
            include_value));
 
        return proxy::IListImpl::add_item_listener(std::move(itemEventHandler),
                                                   include_value);
    }
 
    template<typename E>
    boost::future<bool> contains(const E& element)
    {
        return proxy::IListImpl::contains(to_data(element));
    }
 
    template<typename E>
    boost::future<std::vector<E>> to_array()
    {
        return to_object_vector<E>(proxy::IListImpl::to_array_data());
    }
 
    template<typename E>
    boost::future<bool> add(const E& element)
    {
        return proxy::IListImpl::add(to_data(element));
    }
 
    template<typename E>
    boost::future<bool> remove(const E& element)
    {
        return proxy::IListImpl::remove(to_data(element));
    }
 
    template<typename E>
    boost::future<bool> contains_all(const std::vector<E>& elements)
    {
        return proxy::IListImpl::contains_all_data(
          to_data_collection(elements));
    }
 
    template<typename E>
    boost::future<bool> add_all(const std::vector<E>& elements)
    {
        return proxy::IListImpl::add_all_data(to_data_collection(elements));
    }
 
    template<typename E>
    boost::future<bool> add_all(int32_t index, const std::vector<E>& elements)
    {
        return proxy::IListImpl::add_all_data(index,
                                              to_data_collection(elements));
    }
 
    template<typename E>
    boost::future<bool> remove_all(const std::vector<E>& elements)
    {
        return proxy::IListImpl::remove_all_data(to_data_collection(elements));
    }
 
    template<typename E>
    boost::future<bool> retain_all(const std::vector<E>& elements)
    {
        return proxy::IListImpl::retain_all_data(to_data_collection(elements));
    }
 
    template<typename E>
    boost::future<boost::optional<E>> get(int32_t index)
    {
        return to_object<E>(proxy::IListImpl::get_data(index));
    }
 
    template<typename E, typename R = E>
    boost::future<boost::optional<R>> set(int32_t index, const E& element)
    {
        return to_object<R>(
          proxy::IListImpl::set_data(index, to_data(element)));
    }
 
    template<typename E>
    boost::future<void> add(int32_t index, const E& element)
    {
        return proxy::IListImpl::add(index, to_data(element));
    }
 
    template<typename E>
    boost::future<boost::optional<E>> remove(int32_t index)
    {
        return to_object<E>(proxy::IListImpl::remove_data(index));
    }
 
    template<typename E>
    boost::future<int> index_of(const E& element)
    {
        return proxy::IListImpl::index_of(to_data(element));
    }
 
    template<typename E>
    boost::future<int32_t> last_index_of(const E& element)
    {
        return proxy::IListImpl::last_index_of(to_data(element));
    }
 
    template<typename E>
    boost::future<std::vector<E>> sub_list(int32_t from_index, int32_t to_index)
    {
        return to_object_vector<E>(
          proxy::IListImpl::sub_list_data(from_index, to_index));
    }
 
private:
    ilist(const std::string& instance_name, spi::ClientContext* context)
      : proxy::IListImpl(instance_name, context)
    {}
};
} // namespace client
} // namespace hazelcast