Class: DRb::WebSocket::Messages

Inherits:
Object
  • Object
show all
Defined in:
lib/drb/websocket/server.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Messages

Returns a new instance of Messages.



60
61
62
63
 
# File 'lib/drb/websocket/server.rb', line 60

def initialize
  @request_message = Thread::Queue.new
  @reply_message = Thread::Queue.new
end

Instance Method Details

#recv_message(message) ⇒ Object 



65
66
67
68
 
# File 'lib/drb/websocket/server.rb', line 65

def recv_message(message)
  @request_message.push message
  @reply_message.pop
end

#reply(body) ⇒ Object 



74
75
76
 
# File 'lib/drb/websocket/server.rb', line 74

def reply(body)
  @reply_message.push(body)
end

#request_message ⇒ Object 



70
71
72
 
# File 'lib/drb/websocket/server.rb', line 70

def request_message
  @request_message.pop
end