class CZTop::Socket::DISH

Group-based pub/sub (vs topic-based). This is the subscriber socket. @see github.com/zeromq/libzmq/pull/1727

Public Class Methods

new(endpoints = nil) click to toggle source

@param endpoints [String] endpoints to connect to

# File lib/cztop/socket/types.rb, line 223
def initialize(endpoints = nil)
  attach_ffi_delegate(Zsock.new_dish(endpoints))
end

Public Instance Methods

join(group) click to toggle source

Joins the given group. @param group [String] group to join, up to 15 characters @return [void] @raise [ArgumentError] when group name is invalid or group has already

been joined before

@raise [SystemCallError] in case of failure

# File lib/cztop/socket/types.rb, line 233
def join(group)
  rc = ffi_delegate.join(group)
  raise_zmq_err("unable to join group %p" % group) if rc == -1
end
leave(group) click to toggle source

Leaves the given group. @param group [String] group to leave @return [void] @raise [ArgumentError] when group wasn't joined before @raise [SystemCallError] in case of another failure

# File lib/cztop/socket/types.rb, line 243
def leave(group)
  rc = ffi_delegate.leave(group)
  raise_zmq_err("unable to leave group %p" % group) if rc == -1
end