reliable_listener.h

/*
 * Copyright (c) 2008-2021, 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 <cstdint>
 
#include "hazelcast/client/exception/iexception.h"
#include "hazelcast/util/noop.h"
#include "hazelcast/util/type_traits.h"
 
#if  defined(WIN32) || defined(_WIN32) || defined(WIN64) || defined(_WIN64)
#pragma warning(push)
#pragma warning(disable: 4251) //for dll export
#endif
 
namespace hazelcast {
    namespace client {
        class reliable_topic;
        namespace topic {
            class message;
 
            class HAZELCAST_API reliable_listener final {
                friend class client::reliable_topic;
            public:
                explicit reliable_listener(bool loss_tolerant, int64_t initial_sequence_id = -1);
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &on_received(Handler &&h) & {
                    received_ = std::move(h);
                    return *this;
                }
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &&on_received(Handler &&h) && {
                    on_received(std::move(h));
                    return std::move(*this);
                }
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &on_store_sequence_id(Handler &&h) & {
                    store_sequence_id_ = std::move(h);
                    return *this;
                }
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &&on_store_sequence_id(Handler &&h) && {
                    on_store_sequence_id(std::move(h));
                    return std::move(*this);
                }
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &terminate_on_exception(Handler &&h) & {
                    terminal_ = std::move(h);
                    return *this;
                }
 
                template<typename Handler,
                         typename = util::enable_if_rvalue_ref_t<Handler &&>>
                reliable_listener &&terminate_on_exception(Handler &&h) && {
                    terminate_on_exception(std::move(h));
                    return std::move(*this);
                }
 
            private:
                using received_handler_t = std::function<void(message &&)>;
                using store_sequence_id_handler_t = std::function<void(int64_t)>;
                using exception_handler_t = std::function<bool(const exception::iexception &)>;
 
                bool loss_tolerant_;
                int64_t initial_sequence_id_;
 
                received_handler_t received_{ util::noop<message &&> };
                store_sequence_id_handler_t store_sequence_id_ { util::noop<int64_t> };
                exception_handler_t terminal_{ 
                    [](const exception::iexception &){
                        return false;
                    }
                };
            };
 
        }
    }
}
 
#if  defined(WIN32) || defined(_WIN32) || defined(WIN64) || defined(_WIN64)
#pragma warning(pop)
#endif