lib/daybreak/queue/threaded.rb in daybreak-0.2.1 vs lib/daybreak/queue/threaded.rb in daybreak-0.2.2
- old
+ new
@@ -21,11 +21,11 @@
@queue.shift
@empty.signal if @queue.empty?
end
end
- def next
+ def first
@mutex.synchronize do
@full.wait(@mutex) while @queue.empty?
@queue.first
end
end
@@ -33,7 +33,10 @@
def flush
@mutex.synchronize do
@empty.wait(@mutex) until @queue.empty?
end
end
+
+ def close
+ end
end
-end
\ No newline at end of file
+end