Module: Sequel::Database::AsyncThreadPool

Defined in:

lib/sequel/extensions/async_thread_pool.rb

Defined Under Namespace

Modules: DatabaseMethods, DatasetMethods Classes: BaseProxy, JobProcessor, PreemptableProxy, Proxy, WrappedException

Constant Summary

ASYNC_METHODS =

([:all?, :any?, :drop, :entries, :grep_v, :include?, :inject, :member?, :minmax, :none?, :one?, :reduce, :sort, :take, :tally, :to_a, :to_h, :uniq, :zip] & Enumerable.instance_methods) + (Dataset::ACTION_METHODS - [:map, :paged_each])

ASYNC_BLOCK_METHODS =

([:collect, :collect_concat, :detect,  :drop_while, :each_cons, :each_entry, :each_slice, :each_with_index, :each_with_object, :filter_map, :find, :find_all, :find_index, :flat_map, :max_by, :min_by, :minmax_by, :partition, :reject, :reverse_each, :sort_by, :take_while] & Enumerable.instance_methods) + [:paged_each]

ASYNC_ARGS_OR_BLOCK_METHODS =

[:map]