Contents

# frozen_string_literal: true

require 'bundler/setup'
require 'jstreams'

STDOUT.sync = true
logger = Logger.new(STDOUT)

logger.info 'Starting publisher...'

jstreams = Jstreams::Context.new logger: logger

loop do
  body = "hello #{Time.now}"
  id = jstreams.publish('mystream', body)
  logger.info "published: #{id} - #{body}"
  sleep(1)
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jstreams-0.1.0.alpha	examples/basic/example_publisher.rb