Contents

module Restruct
  class Channel < Structure

    def publish(message)
      connection.call 'PUBLISH', id, serialize(message)
    end

    def subscribe
      subscriber = connection.clone
      subscriber.call 'SUBSCRIBE', id
      loop do
        yield deserialize(subscriber.read.last)
      end
    rescue => ex
      raise ex
    ensure
      subscriber.call 'UNSUBSCRIBE', id
    end

    private

    def serialize(string)
      string
    end

    def deserialize(string)
      string
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
restruct-0.2.0	lib/restruct/channel.rb