Method: Mongo::TimeoutThread#initialize

Defined in:
lib/jmongo/mongo/utils.rb

#initialize(collection, doc, timeout) ⇒ TimeoutThread

Returns a new instance of TimeoutThread.



7
8
9
10
11
12
13
 
# File 'lib/jmongo/mongo/utils.rb', line 7

def initialize(collection, doc, timeout)
  @collection = collection
  @doc = doc
  @timeout = timeout
  @queue = SizedQueue.new(1)
  spawn_thread
end