BookListeners.h

#pragma once
 
#include <xrpl/protocol/MultiApiJson.h>
#include <xrpl/server/InfoSub.h>
 
#include <memory>
#include <mutex>
 
namespace xrpl {
 
class BookListeners
{
public:
    using pointer = std::shared_ptr<BookListeners>;
 
    BookListeners()
    {
    }
 
    void
    addSubscriber(InfoSub::ref sub);
 
    void
    removeSubscriber(std::uint64_t sub);
 
    void
    publish(MultiApiJson const& jvObj, hash_set<std::uint64_t>& havePublished);
 
private:
    std::recursive_mutex mLock;
 
    hash_map<std::uint64_t, InfoSub::wptr> mListeners;
};
 
}  // namespace xrpl