Classes and Modules
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. |