Contents

require "thread_safe"

class OutputStream
  
  def initialize(deploy)
    @deploy = deploy
    @lines = ThreadSafe::Array.new
  end
  
  def <<(value)
    @lines.push(value)
    begin
      @deploy.update_column :output, to_s
    rescue exceptions_wrapping(PG::ConnectionBad)
      # Be lazy about writing this to the database
      # Better yet, !todo, debounce this
      Rails.logger.warn "#{$!.class}: #{$!.message}"
    end
    self
  end
  
  def to_s
    @lines.join
  end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
houston-core-0.5.0.beta1	app/models/output_stream.rb