/*
* call-seq:
* conn.get_notify()
*
* Returns an array of the unprocessed notifiers.
* If there is no unprocessed notifier, it returns +nil+.
*/
static VALUE
pgconn_get_notify(obj)
VALUE obj;
{
PGnotify *notify;
VALUE ary;
/* gets notify and builds result */
notify = PQnotifies(get_pgconn(obj));
if (notify == NULL) {
/* there are no unhandled notifications */
return Qnil;
}
ary = rb_ary_new3(2, rb_tainted_str_new2(notify->relname),
INT2NUM(notify->be_pid));
free(notify);
/* returns result */
return ary;
}