Class: DRb::WebSocket::Callback

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

Instance Method Summary collapse

Constructor Details

#initialize(drb) ⇒ Callback

Returns a new instance of Callback.



21
22
23
24
 
# File 'lib/drb/websocket/server.rb', line 21

def initialize(drb)
  @drb = drb
  @queue = Thread::Queue.new
end

Instance Method Details

#close ⇒ Object 



40
 
# File 'lib/drb/websocket/server.rb', line 40

def close; end

#message ⇒ Object 



32
33
34
 
# File 'lib/drb/websocket/server.rb', line 32

def message
  @msg
end

#recv_mesg(msg) ⇒ Object 



26
27
28
29
30
 
# File 'lib/drb/websocket/server.rb', line 26

def recv_mesg(msg)
  @msg = msg
  @drb.push(self)
  @queue.pop
end

#reply(body) ⇒ Object 



36
37
38
 
# File 'lib/drb/websocket/server.rb', line 36

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