Sha256: d8fd95a9934183af2ec3b13c399c936468f7d5f3b7390695583e7d1b2bb721bb
Contents?: true
Size: 489 Bytes
Versions: 113
Compression:
Stored size: 489 Bytes
Contents
# frozen_string_literal: true
require 'bundler/setup'
require 'polyphony/adapters/redis'
spin do
redis = Redis.new
redis.subscribe('redis-channel') do |on|
on.message do |channel, message|
puts "##{channel}: #{message}"
redis.unsubscribe if message == 'exit'
end
end
end
spin do
redis = Redis.new
move_on_after(3) do
throttled_loop(1) do
redis.publish('redis-channel', Time.now)
end
end
redis.publish('redis-channel', 'exit')
end
suspend
Version data entries
113 entries across 113 versions & 1 rubygems