Module: Database::ConcurrentThreadPool

Defined in:

lib/sequel/extensions/concurrent_thread_pool.rb

Overview

github.com/jeremyevans/sequel/blob/master/lib/sequel/extensions/async_thread_pool.rb

Defined Under Namespace

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

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])).freeze

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]).freeze

ASYNC_ARGS_OR_BLOCK_METHODS =

[:map].freeze