Subscription.hpp

#ifndef _DITTO_SUBSCRIPTION_
#define _DITTO_SUBSCRIPTION_
 
#include "Observer.hpp"
#include "json.hpp"
 
#include <memory>
#include <string>
 
namespace ditto {
class DittoHandleWrapper;
class OrderBy;
 
class Subscription : public Observer {
  friend class PendingIDSpecificOperation;
  friend class PendingCursorOperation;
 
  std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper;
  nlohmann::json query_args;
  std::shared_ptr<OrderBy> order_by;
  int32_t limit = -1;
  uint32_t offset = 0;
 
  Subscription(std::shared_ptr<DittoHandleWrapper> ditto_handle_wrapper,
               std::string query, nlohmann::json query_args,
               std::shared_ptr<OrderBy> order_by, int32_t limit,
               uint32_t offset, std::string collection_name);
 
  void on_stop() override;
 
public:
  std::string query;
 
  std::string collection_name;
 
  ~Subscription();
};
} // namespace ditto
#endif