subscriber.h

 
#ifndef MDB_SUBSCRIBER_H
#define MDB_SUBSCRIBER_H
 
#include <stdbool.h>
 
#include "mdb/connection.h"
#include "mdb/error.h"
#include "mdb/signatures.h"
#include "mdb/subscriber_config.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct mdb_subscriber mdb_subscriber_t;
 
mdb_subscriber_t *mdb_subscriber_create_async(mdb_connection_t *connection,
                                              mdb_subscriber_config_t *config,
                                              mdb_on_done_t on_done,
                                              void *user_data,
                                              mdb_error_t **error);
 
bool mdb_subscriber_manual_subscribe_async(mdb_subscriber_t *self,
                                           mdb_on_done_t on_done,
                                           void *user_data,
                                           mdb_error_t **error);
 
void mdb_subscriber_destroy(mdb_subscriber_t **self);
 
#ifdef __cplusplus
}
#endif
 
#endif