module Database::AsyncThreadPool

  1. lib/sequel/extensions/async_thread_pool.rb
  2. lib/sequel/plugins/async_thread_pool.rb
  3. lib/sequel/plugins/concurrent_eager_loading.rb
  4. show all

Constants

ASYNC_ARGS_OR_BLOCK_METHODS = [:map]  
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_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])  
WrappedException = Struct.new(:exception)  

Wrapper for exception instances raised by async jobs. The wrapped exception will be raised by the code getting the value of the job.