# File lib/brb/tunnel.rb, line 23 def initialize(opts = {}) super @object = opts[:object] @verbose = opts[:verbose] BrB.logger.level = @verbose ? Logger::INFO : Logger::WARN @timeout_rcv_value = opts[:timeout] || 30 # Currently not implemented due to the lack of performance of ruby Timeout @close_after_timeout = opts[:close_after_timeout] || false @uri = opts[:uri] @replock = Mutex.new @responses = {} @block = opts[:block] @queue = Queue.new @buffer = '' # Callbacks handling : @callbacks = {} @callbacks_mutex = Mutex.new end