StoreObserver.hpp

#ifndef _DITTO_STORE_OBSERVER_
#define _DITTO_STORE_OBSERVER_
 
#include "Ditto.hpp"
#include "Document.hpp"
#include "Helpers.hpp"
#include "Observer.hpp"
#include "json.hpp"
 
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
#include "dittoffi.hpp"
 
namespace ditto {
class Store;
class QueryResult;
 
typedef std::function<void(QueryResult)> StoreObservationHandler;
 
typedef std::function<void()> NextSignal;
 
typedef std::function<void(QueryResult, NextSignal)>
    StoreObservationHandlerWithNextSignal;
 
class StoreObserver : Observer,
                      public std::enable_shared_from_this<StoreObserver> {
public:
  ~StoreObserver(); // required by pimpl.
  StoreObserver(StoreObserver &&);
  StoreObserver &operator=(StoreObserver &&);
 
  struct ArcCtx;
 
  void cancel();
 
  bool is_cancelled();
 
private:
  void on_stop() override;
  StoreObserver(std::weak_ptr<Ditto::Fields> weak_ditto_fields,
                std::string query, nlohmann::json query_args,
                LiveQueryAvailability_t,
                StoreObservationHandlerWithNextSignal event_callback);
  int64_t id();
 
  std::unique_ptr<ArcCtx> ctx; // pimpl.
 
  friend class Store;
};
 
} // namespace ditto
 
#endif