PendingQuery.h

Go to the documentation of this file.

#ifndef MEDUSA_PENDINGQUERY_H
#define MEDUSA_PENDINGQUERY_H

#include "common.h"

MEDUSA_NAMESPACE_BEGIN

// --------------------------------------------------
class PendingQuery {
  public:
    PendingQuery(ptr<Query> query) : m_query(query) {}        
    ~PendingQuery() {}

    ptr<Query> m_query;
    
    // Completion for initial request
    AsyncRPC<void> completion;

};

// --------------------------------------------------
class PendingBatch {

 public:
    PendingBatch(int nb_queries) 
        : m_nb_queries(nb_queries) {}
    ~PendingBatch() {}

    int m_nb_queries;
    AsyncRPC<void> completion;
    
};

MEDUSA_NAMESPACE_END


#endif

---