BookListeners.h

#ifndef XRPL_APP_LEDGER_BOOKLISTENERS_H_INCLUDED
#define XRPL_APP_LEDGER_BOOKLISTENERS_H_INCLUDED
 
#include <xrpld/rpc/InfoSub.h>
 
#include <xrpl/protocol/MultiApiJson.h>
 
#include <memory>
#include <mutex>
 
namespace ripple {
 
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 ripple
 
#endif