Update RBI files for concurrent-ruby.

This commit is contained in:
BrewTestBot 2022-03-22 18:24:48 +00:00
parent 25dcb7e675
commit d0f5a1e149
No known key found for this signature in database
GPG Key ID: 82D7D104050B0F0F
2 changed files with 28 additions and 21 deletions

View File

@ -1,9 +1,9 @@
# typed: true
# DO NOT EDIT MANUALLY # DO NOT EDIT MANUALLY
# This is an autogenerated file for types exported from the `concurrent-ruby` gem. # This is an autogenerated file for types exported from the `concurrent-ruby` gem.
# Please instead update this file by running `bin/tapioca gem concurrent-ruby`. # Please instead update this file by running `bin/tapioca gem concurrent-ruby`.
# typed: true
module Concurrent module Concurrent
extend ::Concurrent::Utility::EngineDetector extend ::Concurrent::Utility::EngineDetector
extend ::Concurrent::Utility::NativeExtensionLoader extend ::Concurrent::Utility::NativeExtensionLoader
@ -21,7 +21,7 @@ module Concurrent
def dataflow_with(executor, *inputs, &block); end def dataflow_with(executor, *inputs, &block); end
def dataflow_with!(executor, *inputs, &block); end def dataflow_with!(executor, *inputs, &block); end
def leave_transaction; end def leave_transaction; end
def monotonic_time; end def monotonic_time(unit = T.unsafe(nil)); end
class << self class << self
def abort_transaction; end def abort_transaction; end
@ -42,7 +42,7 @@ module Concurrent
def global_logger=(value); end def global_logger=(value); end
def global_timer_set; end def global_timer_set; end
def leave_transaction; end def leave_transaction; end
def monotonic_time; end def monotonic_time(unit = T.unsafe(nil)); end
def new_fast_executor(opts = T.unsafe(nil)); end def new_fast_executor(opts = T.unsafe(nil)); end
def new_io_executor(opts = T.unsafe(nil)); end def new_io_executor(opts = T.unsafe(nil)); end
def physical_processor_count; end def physical_processor_count; end
@ -89,7 +89,7 @@ class Concurrent::AbstractExecutorService < ::Concurrent::Synchronization::Locka
private private
def handle_fallback(*args); end def fallback_action(*args); end
def ns_auto_terminate?; end def ns_auto_terminate?; end
def ns_execute(*args, &task); end def ns_execute(*args, &task); end
def ns_kill_execution; end def ns_kill_execution; end
@ -722,7 +722,6 @@ Concurrent::GLOBAL_FAST_EXECUTOR = T.let(T.unsafe(nil), Concurrent::Delay)
Concurrent::GLOBAL_IMMEDIATE_EXECUTOR = T.let(T.unsafe(nil), Concurrent::ImmediateExecutor) Concurrent::GLOBAL_IMMEDIATE_EXECUTOR = T.let(T.unsafe(nil), Concurrent::ImmediateExecutor)
Concurrent::GLOBAL_IO_EXECUTOR = T.let(T.unsafe(nil), Concurrent::Delay) Concurrent::GLOBAL_IO_EXECUTOR = T.let(T.unsafe(nil), Concurrent::Delay)
Concurrent::GLOBAL_LOGGER = T.let(T.unsafe(nil), Concurrent::AtomicReference) Concurrent::GLOBAL_LOGGER = T.let(T.unsafe(nil), Concurrent::AtomicReference)
Concurrent::GLOBAL_MONOTONIC_CLOCK = T.let(T.unsafe(nil), T.untyped)
Concurrent::GLOBAL_TIMER_SET = T.let(T.unsafe(nil), Concurrent::Delay) Concurrent::GLOBAL_TIMER_SET = T.let(T.unsafe(nil), Concurrent::Delay)
class Concurrent::Hash < ::Hash; end class Concurrent::Hash < ::Hash; end
Concurrent::HashImplementation = Hash Concurrent::HashImplementation = Hash
@ -1784,14 +1783,14 @@ class Concurrent::RubyThreadPoolExecutor < ::Concurrent::RubyExecutorService
def max_length; end def max_length; end
def max_queue; end def max_queue; end
def min_length; end def min_length; end
def prune_pool; end
def queue_length; end def queue_length; end
def ready_worker(worker); end def ready_worker(worker, last_message); end
def remaining_capacity; end def remaining_capacity; end
def remove_busy_worker(worker); end def remove_busy_worker(worker); end
def scheduled_task_count; end def scheduled_task_count; end
def synchronous; end def synchronous; end
def worker_died(worker); end def worker_died(worker); end
def worker_not_old_enough(worker); end
def worker_task_completed; end def worker_task_completed; end
private private
@ -1804,12 +1803,11 @@ class Concurrent::RubyThreadPoolExecutor < ::Concurrent::RubyExecutorService
def ns_kill_execution; end def ns_kill_execution; end
def ns_limited_queue?; end def ns_limited_queue?; end
def ns_prune_pool; end def ns_prune_pool; end
def ns_ready_worker(worker, success = T.unsafe(nil)); end def ns_ready_worker(worker, last_message, success = T.unsafe(nil)); end
def ns_remove_busy_worker(worker); end def ns_remove_busy_worker(worker); end
def ns_reset_if_forked; end def ns_reset_if_forked; end
def ns_shutdown_execution; end def ns_shutdown_execution; end
def ns_worker_died(worker); end def ns_worker_died(worker); end
def ns_worker_not_old_enough(worker); end
end end
Concurrent::RubyThreadPoolExecutor::DEFAULT_MAX_POOL_SIZE = T.let(T.unsafe(nil), Integer) Concurrent::RubyThreadPoolExecutor::DEFAULT_MAX_POOL_SIZE = T.let(T.unsafe(nil), Integer)
@ -2216,11 +2214,9 @@ end
class Concurrent::TVar < ::Concurrent::Synchronization::Object class Concurrent::TVar < ::Concurrent::Synchronization::Object
def initialize(value); end def initialize(value); end
def unsafe_increment_version; end
def unsafe_lock; end def unsafe_lock; end
def unsafe_value; end def unsafe_value; end
def unsafe_value=(value); end def unsafe_value=(value); end
def unsafe_version; end
def value; end def value; end
def value=(value); end def value=(value); end
@ -2285,7 +2281,6 @@ class Concurrent::TimerTask < ::Concurrent::RubyExecutorService
def ns_kill_execution; end def ns_kill_execution; end
def ns_shutdown_execution; end def ns_shutdown_execution; end
def schedule_next_task(interval = T.unsafe(nil)); end def schedule_next_task(interval = T.unsafe(nil)); end
def timeout_task(completion); end
class << self class << self
def execute(opts = T.unsafe(nil), &task); end def execute(opts = T.unsafe(nil), &task); end
@ -2300,9 +2295,9 @@ class Concurrent::Transaction
def abort; end def abort; end
def commit; end def commit; end
def open(tvar); end
def read(tvar); end def read(tvar); end
def unlock; end def unlock; end
def valid?; end
def write(tvar, value); end def write(tvar, value); end
class << self class << self
@ -2315,11 +2310,11 @@ Concurrent::Transaction::ABORTED = T.let(T.unsafe(nil), Object)
class Concurrent::Transaction::AbortError < ::StandardError; end class Concurrent::Transaction::AbortError < ::StandardError; end
class Concurrent::Transaction::LeaveError < ::StandardError; end class Concurrent::Transaction::LeaveError < ::StandardError; end
class Concurrent::Transaction::ReadLogEntry < ::Struct class Concurrent::Transaction::OpenEntry < ::Struct
def tvar; end def modified; end
def tvar=(_); end def modified=(_); end
def version; end def value; end
def version=(_); end def value=(_); end
class << self class << self
def [](*_arg0); end def [](*_arg0); end

View File

@ -3488,7 +3488,13 @@ end
Net::HTTPFatalErrorCode = Net::HTTPClientError Net::HTTPFatalErrorCode = Net::HTTPClientError
Net::HTTPInformationCode = Net::HTTPInformation class Net::HTTPInformation
end
Net::HTTPInformationCode::EXCEPTION_TYPE = Net::HTTPError
class Net::HTTPInformation
end
class Net::HTTPLoopDetected class Net::HTTPLoopDetected
HAS_BODY = ::T.let(nil, ::T.untyped) HAS_BODY = ::T.let(nil, ::T.untyped)
@ -3548,7 +3554,13 @@ Net::HTTPServerErrorCode = Net::HTTPServerError
Net::HTTPSession = Net::HTTP Net::HTTPSession = Net::HTTP
Net::HTTPSuccessCode = Net::HTTPSuccess class Net::HTTPSuccess
end
Net::HTTPSuccessCode::EXCEPTION_TYPE = Net::HTTPError
class Net::HTTPSuccess
end
class Net::HTTPURITooLong class Net::HTTPURITooLong
HAS_BODY = ::T.let(nil, ::T.untyped) HAS_BODY = ::T.let(nil, ::T.untyped)