Class: EZMQ::Subscriber

Inherits:

Socket

• Object
• Socket
• EZMQ::Subscriber

show all

Defined in:

lib/ezmq.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) action

  Returns the value of attribute action.

Attributes inherited from Socket

#context, #decode, #encode, #socket

Instance Method Summary (collapse)

• - (Publisher) initialize(action: -> m { m }, **options) constructor

  Creates a new Subscriber socket.

• - (void) listen(handler: -> { @action.call(receive) })

  By default, waits for a message and calls @action with the message.

• - (Boolean) subscribe(topic)

  Establishes a new message filter on the socket.

• - (Boolean) unsubscribe(topic)

  Removes a message filter (as set with subscribe) from the socket.

Methods inherited from Socket

#bind, #connect, #receive, #send

185
186
187
188
189

# File 'lib/ezmq.rb', line 185

def initialize(action: -> m { m }, **options)
  @action = action
  super :connect, ZMQ::SUB, options
  subscribe options[:topic] if options[:topic]
end

172
173
174

# File 'lib/ezmq.rb', line 172

def action
  @action
end

223
224
225

# File 'lib/ezmq.rb', line 223

def listen(handler: -> { @action.call(receive) })
  loop { handler.call }
end

202
203
204

# File 'lib/ezmq.rb', line 202

def subscribe(topic)
  @socket.setsockopt(ZMQ::SUBSCRIBE, topic) == 0 ? true : false
end

213
214
215

# File 'lib/ezmq.rb', line 213

def unsubscribe(topic)
  @socket.setsockopt(ZMQ::UNSUBSCRIBE, topic) == 0 ? true : false
end