lib/roda/plugins/streaming.rb
def enqueue_chunks
          @stream.each do |chunk|
            @queue.push(chunk)
          end
        rescue ClosedQueueError
          # connection was closed
        ensure
          @queue.close
        end
# Push each streaming chunk onto the queue.
Push each streaming chunk onto the queue.
Push each streaming chunk onto the queue .
def enqueue_chunks
          @stream.each do |chunk|
            @queue.push(chunk)
          end
        rescue ClosedQueueError
        ensure
          @queue.close
        end
def enqueue_chunks @stream . each do | chunk | @queue . push ( chunk ) end rescue ClosedQueueError ensure @queue . close end
Push each streaming chunk onto the queue.
Push each streaming chunk onto the queue .
# connection was closed