Class: Celluloid::ZMQ::Mailbox

Inherits:

IO::Mailbox

• Object
• IO::Mailbox
• Celluloid::ZMQ::Mailbox

Defined in:

lib/celluloid/zmq/mailbox.rb

Overview

A Celluloid mailbox for Actors that wait on 0MQ sockets

Instance Method Summary

• #initialize ⇒ Mailbox constructor

  A new instance of Mailbox.

Constructor Details

#initialize ⇒ Mailbox

Returns a new instance of Mailbox.

# File 'lib/celluloid/zmq/mailbox.rb', line 5

def initialize
  @messages = []
  @lock  = Mutex.new
  @waker = Celluloid::ZMQ::Waker.new
  @reactor = Reactor.new(@waker)
end