Module: OMQ::Readable

Includes:
QueueReadable
Included in:
DEALER, PAIR, PULL, REP, REQ, ROUTER, SUB, XPUB, XSUB
Defined in:
lib/omq/readable.rb

Overview

Pure Ruby Readable mixin. Dequeues messages from the engine’s recv queue.

Instance Method Summary collapse

Methods included from QueueReadable

#dequeue, #each, #wait

Instance Method Details

#receive ⇒ Array<String>

Receives the next message directly from the engine recv queue.

Returns:

  • (Array<String>) —

    message parts

Raises:

  • (IO::TimeoutError) —

    if read_timeout exceeded



16
17
18
19
20
 
# File 'lib/omq/readable.rb', line 16

def receive
  Reactor.run timeout: @options.read_timeout do |task|
    @engine.dequeue_recv
  end
end

#wait_readable(timeout = @options.read_timeout) ⇒ true

Waits until the socket is readable.

Parameters:

  • timeout (Numeric, nil) (defaults to: @options.read_timeout) —

    timeout in seconds

Returns:

  • (true) 


28
29
30
 
# File 'lib/omq/readable.rb', line 28

def wait_readable(timeout = @options.read_timeout)
  true
end