Class: NanoMsg::SubSocket

Inherits:

Socket

• Object
• Socket
• NanoMsg::SubSocket

Defined in:

ext/init.c

Instance Method Summary

• #initialize ⇒ Object constructor
• #subscribe(channel) ⇒ Object
• #unsubscribe(channel) ⇒ Object

Methods inherited from Socket

#bind, #close, #connect, #recv, #send, #setsockopt

Constructor Details

#initialize ⇒ Object

Instance Method Details

#subscribe(channel) ⇒ Object

# File 'ext/init.c', line 319

static VALUE
sub_sock_subscribe(VALUE socket, VALUE channel)
{
  int sock = sock_get(socket);
  int err;

  err = nn_setsockopt(
    sock, NN_SUB, NN_SUB_SUBSCRIBE,
    StringValuePtr(channel),
    RSTRING_LEN(channel)
  );
  if (err < 0)
    RAISE_SOCK_ERROR;

  return socket;
}

#unsubscribe(channel) ⇒ Object

# File 'ext/init.c', line 336

static VALUE
sub_sock_unsubscribe(VALUE socket, VALUE channel)
{
  int sock = sock_get(socket);
  int err;

  err = nn_setsockopt(
    sock, NN_SUB, NN_SUB_UNSUBSCRIBE,
    StringValuePtr(channel),
    RSTRING_LEN(channel)
  );
  if (err < 0)
    RAISE_SOCK_ERROR;

  return socket;
}