Method: NNG::Socket::Rep0#send_msg

Defined in:
ext/rbnng/rep0.c

#send_msg(rb_strMsg) ⇒ Object



105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
# File 'ext/rbnng/rep0.c', line 105

static VALUE
socket_rep0_send_msg(VALUE self, VALUE rb_strMsg)
{
  Check_Type(rb_strMsg, T_STRING);

  RbnngSendMsgReq sendMsgReq = {
    .socketObj = self,
    .nextMsg = rb_strMsg,
  };
  int rv =
    rb_thread_call_without_gvl(rep0_send_msg_blocking, &sendMsgReq, 0, 0);
  if (rv != 0) {
    raise_error(rv);
  }
}