Sha256: 00b249f4d1e943022180af7e8a491177e29e177e3ea3ce92651f875e57d87a18
Contents?: true
Size: 677 Bytes
Versions: 33
Compression:
Stored size: 677 Bytes
Contents
module ZK
# the subscription object that is passed back from subscribing
# to events.
# @see ZK::Client::Base#register
module EventHandlerSubscription
# @private
def self.class_for_thread_option(thopt)
case thopt
when :single
Base
when :per_callback
Actor
else
raise ArgumentError, "Unrecognized :thread option: #{thopt}"
end
end
def self.new(*a, &b)
opts = a.extract_options!
klass = class_for_thread_option(opts.delete(:thread))
a << opts
klass.new(*a, &b)
end
end
end
require 'zk/event_handler_subscription/base'
require 'zk/event_handler_subscription/actor'
Version data entries
33 entries across 33 versions & 1 rubygems