ext/iodine/iodine_pubsub.c
/** Must subscribe channel. Failures are ignored. */
Must subscribe channel. Failures are ignored.
Must subscribe channel . Failures are ignored .
static void iodine_pubsub_on_subscribe(const fio_pubsub_engine_s *eng,
                                       fio_str_info_s channel,
                                       fio_match_fn match) {
  if (iodine_engine(eng)->handler == Qnil) {
    return;
  }
  iodine_pubsub_task_s task = {
      .eng = iodine_engine(eng), .ch = channel, .pattern = match};
  IodineCaller.enterGVL(iodine_pubsub_GIL_subscribe, &task);
}
static void iodine_pubsub_on_subscribe ( const fio_pubsub_engine_s * eng , fio_str_info_s channel , fio_match_fn match ) { if ( iodine_engine ( eng ) -> handler == Qnil ) { return ; } iodine_pubsub_task_s task = { . eng = iodine_engine ( eng ) , . ch = channel , . pattern = match } ; IodineCaller . enterGVL ( iodine_pubsub_GIL_subscribe , & task ) ; }
Must subscribe channel.
Must subscribe channel .