gistfile1.txt

require 'concurrent'

class Test
  def update(time, value, reason)
    puts "OMG"
  end
end

puts 'testing . . .'

future = Concurrent::Future.new { 'concurrent thread' }
future.add_observer(Test.new)

future.execute