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