Module: CZTop::SendReceiveMethods

Included in:

Actor, Socket

Defined in:

lib/cztop/send_receive_methods.rb

Overview

These are methods that can be used on a Socket as well as an Actor, but actually just pass through to methods of Message (which take a polymorphic reference, in Ruby as well as in C).

See Also:

• http://api.zeromq.org/czmq3-0:zmsg

Instance Method Summary

• #<<(message) ⇒ self

  Sends a message.

• #receive ⇒ Message

  Receives a message.

Instance Method Details

#<<(message) ⇒ self

Sends a message.

Parameters:

• message (Message, String, Array<parts>) —

  the message to send

Returns:

• (self)

Raises:

• (IO::EAGAINWaitWritable) —

  if send timeout has been reached (see ZsockOptions::OptionsAccessor#sndtimeo=)

• (Interrupt, ArgumentError, SystemCallError) —

  anything raised by Message#send_to

See Also:

• Message.coerce
• Message#send_to

# File 'lib/cztop/send_receive_methods.rb', line 18

def <<(message)
  Message.coerce(message).send_to(self)
  self
end

#receive ⇒ Message

Receives a message.

Returns:

• (Message)

Raises:

• (IO::EAGAINWaitReadable) —

  if receive timeout has been reached (see ZsockOptions::OptionsAccessor#rcvtimeo=)

• (Interrupt, ArgumentError, SystemCallError) —

  anything raised by Message.receive_from

See Also:

• Message.receive_from

# File 'lib/cztop/send_receive_methods.rb', line 31

def receive
  Message.receive_from(self)
end