Method: Fairy::FileMarshaledQueue#pop_all

Defined in:
lib/fairy/share/port-marshaled-queue.rb

#pop_all ⇒ Object 



274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
 
# File 'lib/fairy/share/port-marshaled-queue.rb', line 274

def pop_all
  while !@pop_queue
  @buffers_queue_mon.synchronize do
    buf = nil
    @buffers_queue_cv.wait_until{buf = @buffers_queue.shift}
    if buf == :END_OF_STREAM
 @pop_queue = [buf]
    else
 @pop_queue = restore_2ndmemory(buf)
    end
  end
  end
  buf, @pop_queue = @pop_queue, nil
  buf
end