Contents

# frozen_string_literal: true

require "redis"

module SuperSpreader
  module StopSignal
    def stop!
      redis.set(stop_key, true)
    end

    def go!
      redis.del(stop_key)
    end

    def stopped?
      redis.exists(stop_key).positive?
    end

    private

    def redis
      SuperSpreader.redis
    end

    def stop_key
      "#{name}:stop"
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
super_spreader-0.2.1	lib/super_spreader/stop_signal.rb
super_spreader-0.2.0	lib/super_spreader/stop_signal.rb
super_spreader-0.1.0.beta2	lib/super_spreader/stop_signal.rb