class Concurrent::SafeTaskExecutor

def initialize(task, opts = {})

Experimental RBS support (using type sampling data from the type_fusion project).

def initialize: (Proc task, ?Hash opts) -> void

This signature was generated using 4 samples from 2 applications.

def initialize(task, opts = {})
  @task            = task
  @exception_class = opts.fetch(:rescue_exception, false) ? Exception : StandardError
  super() # ensures visibility
end