class Monsoon::Streams::Console

Public Instance Methods

put_records(stream, records, options = {}) click to toggle source
# File lib/monsoon/streams/console.rb, line 6
def put_records(stream, records, options = {})
  records.each do |r|
    puts "Streaming to #{stream}: #{JSON.pretty_generate(r)}"
  end
end