Class: Waithook::WebsocketClient::Waiter

Inherits:

Object

• Object
• Waithook::WebsocketClient::Waiter

Defined in:

lib/waithook/websocket_client.rb

Overview

Waiter object, blocking current thread. Better abstraction for ruby’s Queue utility class

message_waiter = Waiter.new
Thread.new { sleep 5; message_waiter.notify('Done!!!') }
message_waiter.wait # => return 'Done!!!' after 5 seconds pause

Instance Method Summary

• #notify(data) ⇒ Object

  Notify waiting side.

• #wait ⇒ Object

  Waiting for someone to call #notify.

Instance Method Details

#notify(data) ⇒ Object

Notify waiting side

# File 'lib/waithook/websocket_client.rb', line 35

def notify(data)
  @queue.push(data)
end

#wait ⇒ Object

Waiting for someone to call #notify

# File 'lib/waithook/websocket_client.rb', line 29

def wait
  @queue = Queue.new
  @queue.pop(false)
end