Sha256: c9dc6ee333f2b0606028722bfd838395c2acbf70d2a54b0631fb92fba67012dc

Contents?: true

Size: 1.48 KB

Versions: 30

Compression:

Stored size: 1.48 KB

Contents

class Redis
  class SubscribedClient
    def initialize(client)
      @client = client
    end

    def call(*args)
      @client.process(args)
    end

    def subscribe(*channels, &block)
      subscription("subscribe", "unsubscribe", channels, block)
    end

    def psubscribe(*channels, &block)
      subscription("psubscribe", "punsubscribe", channels, block)
    end

    def unsubscribe(*channels)
      call(:unsubscribe, *channels)
    end

    def punsubscribe(*channels)
      call(:punsubscribe, *channels)
    end

  protected

    def subscription(start, stop, channels, block)
      sub = Subscription.new(&block)

      begin
        @client.call_loop(start, *channels) do |line|
          type, *rest = line
          sub.callbacks[type].call(*rest)
          break if type == stop && rest.last == 0
        end
      ensure
        send(stop)
      end
    end
  end

  class Subscription
    attr :callbacks

    def initialize
      @callbacks = Hash.new do |hash, key|
        hash[key] = lambda { |*_| }
      end

      yield(self)
    end

    def subscribe(&block)
      @callbacks["subscribe"] = block
    end

    def unsubscribe(&block)
      @callbacks["unsubscribe"] = block
    end

    def message(&block)
      @callbacks["message"] = block
    end

    def psubscribe(&block)
      @callbacks["psubscribe"] = block
    end

    def punsubscribe(&block)
      @callbacks["punsubscribe"] = block
    end

    def pmessage(&block)
      @callbacks["pmessage"] = block
    end
  end
end

Version data entries

30 entries across 30 versions & 3 rubygems

Version Path
modesty-0.1.0 vendor/redis-rb/lib/redis/subscribe.rb
redis-2.2.0 lib/redis/subscribe.rb
redis-2.1.1 lib/redis/subscribe.rb
redis-2.1.0 lib/redis/subscribe.rb
redis-2.1.0.beta lib/redis/subscribe.rb
redis-2.0.13 lib/redis/subscribe.rb
redis-2.0.12 lib/redis/subscribe.rb
redis-2.0.11 lib/redis/subscribe.rb
redis-2.0.10 lib/redis/subscribe.rb
redis-2.0.9 lib/redis/subscribe.rb
redis-2.0.8 lib/redis/subscribe.rb
redis-2.0.7 lib/redis/subscribe.rb
redis-2.0.6 lib/redis/subscribe.rb
redis-2.0.5 lib/redis/subscribe.rb
redis-2.0.4 lib/redis/subscribe.rb
redis-2.0.3 lib/redis/subscribe.rb
redis-2.0.2 lib/redis/subscribe.rb
redis-2.0.1 lib/redis/subscribe.rb
lunar-0.4.1 vendor/redis/lib/redis/subscribe.rb
redis-2.0.0 lib/redis/subscribe.rb