Module: XRBP::Terminatable

Included in:

WebSocket::Client, WebSocket::Plugins::ConnectionTimeout, WebSocket::Plugins::MessageDispatcher

Defined in:

lib/xrbp/terminatable.rb

Overview

Helper mixin facilitating controlled termination of asynchronous components.

Instance Method Summary

• #terminate! ⇒ Object
• #terminate? ⇒ Boolean
• #terminate_queue ⇒ Object

Instance Method Details

#terminate! ⇒ Object

# File 'lib/xrbp/terminatable.rb', line 15

def terminate!
  terminate_queue << true
end

#terminate? ⇒ Boolean

# File 'lib/xrbp/terminatable.rb', line 11

def terminate?
  !!terminate_queue.pop_or_nil
end

#terminate_queue ⇒ Object

# File 'lib/xrbp/terminatable.rb', line 7

def terminate_queue
  @terminate_queue ||= Queue.new
end