# sig/async/barrier.rbs class Async::Barrier def async: () -> untyped def empty?: () -> untyped def initialize: () -> void def size: () -> untyped def stop: () -> untyped def wait: () -> untyped end # sig/async/barrier.rbs class Async::Barrier::TaskNode < Async::Barrier::List::Node def initialize: () -> void end # sig/async/node.rbs class Async::Children < Async::List def added: () -> untyped def adjust_transient_count: () -> untyped def finished?: () -> untyped def initialize: () -> void def nil?: () -> untyped def removed: () -> untyped def transients?: () -> untyped end # sig/async/clock.rbs class Async::Clock def self.measure: () -> untyped def self.now: () -> untyped def self.start: () -> untyped def as_json: () -> untyped def initialize: () -> void def reset!: () -> untyped def start!: () -> untyped def stop!: () -> untyped def to_json: () -> untyped def total: () -> untyped end # sig/async/condition.rbs class Async::Condition def empty?: () -> untyped def exchange: () -> untyped def initialize: () -> void def signal: () -> untyped def wait: () -> untyped def waiting?: () -> untyped end # sig/async/deadline.rbs class Async::Deadline def self.start: () -> untyped def expired?: () -> untyped def initialize: () -> void def remaining: () -> untyped end # sig/async/idler.rbs class Async::Idler def async: () -> untyped def initialize: () -> void def wait: () -> untyped end # sig/async/limited_queue.rbs class Async::LimitedQueue < Async::Queue def self.new: () -> untyped def initialize: () -> void def limit: () -> untyped def limited?: () -> untyped end # sig/async/list.rbs class Async::List def added: () -> untyped def append: () -> untyped def each: () -> untyped def empty?: () -> untyped def first: () -> untyped def include?: () -> untyped def initialize: () -> void def last: () -> untyped def prepend: () -> untyped def remove: () -> untyped def remove!: () -> untyped def remove?: () -> untyped def removed: () -> untyped def shift: () -> untyped def stack: () -> untyped def to_a: () -> untyped def to_s: () -> untyped end # sig/async/list.rbs class Async::List::Iterator < Async::List::Node def self.each: () -> untyped def each: () -> untyped def initialize: () -> void def move_current: () -> untyped def move_next: () -> untyped def remove!: () -> untyped end # sig/async/list.rbs class Async::List::Node def to_s: () -> untyped end # sig/async/node.rbs class Async::Node def add_child: () -> untyped def annotate: () -> untyped def backtrace: () -> untyped def children?: () -> untyped def consume: () -> untyped def description: () -> untyped def finished?: () -> untyped def initialize: () -> void def parent=: () -> untyped def print_backtrace: () -> untyped def print_hierarchy: () -> untyped def remove_child: () -> untyped def root: () -> untyped def set_parent: () -> untyped def stop: () -> untyped def stop_children: () -> untyped def stopped?: () -> untyped def terminate: () -> untyped def to_s: () -> untyped def transient=: () -> untyped def transient?: () -> untyped def traverse: () -> untyped def traverse_recurse: () -> untyped def wait: () -> untyped end # sig/async/notification.rbs class Async::Notification < Async::Condition def signal: () -> untyped end # sig/async/priority_queue.rbs class Async::PriorityQueue def <<: () -> untyped def async: () -> untyped def close: () -> untyped def closed?: () -> untyped def dequeue: () -> untyped def each: () -> untyped def empty?: () -> untyped def enqueue: () -> untyped def initialize: () -> void def pop: () -> untyped def push: () -> untyped def signal: () -> untyped def size: () -> untyped def wait: () -> untyped def waiting_count: () -> untyped end # sig/async/promise.rbs class Async::Promise def self.fulfill: () -> untyped def cancel: () -> untyped def cancelled?: () -> untyped def completed?: () -> untyped def failed?: () -> untyped def fulfill: () -> untyped def initialize: () -> void def reject: () -> untyped def resolve: () -> untyped def resolved: () -> untyped def resolved?: () -> untyped def suppress_warnings!: () -> untyped def value: () -> untyped def wait: () -> untyped def waiting?: () -> untyped end # sig/async/queue.rbs class Async::Queue def <<: () -> untyped def async: () -> untyped def close: () -> untyped def closed?: () -> untyped def dequeue: () -> untyped def each: () -> untyped def empty?: () -> untyped def enqueue: () -> untyped def initialize: () -> void def pop: () -> untyped def push: () -> untyped def signal: () -> untyped def size: () -> untyped def wait: () -> untyped def waiting_count: () -> untyped end # sig/async/reactor.rbs class Async::Reactor < Async::Scheduler def self.run: () -> untyped def initialize: () -> void def scheduler_close: () -> untyped end # sig/async/scheduler.rbs class Async::Scheduler < Async::Node def self.supported?: () -> untyped def address_resolve: () -> untyped def async: () -> untyped def block: () -> untyped def close: () -> untyped def closed?: () -> untyped def fiber: () -> untyped def fiber_interrupt: () -> untyped def initialize: () -> void def interrupt: () -> untyped def interrupted?: () -> untyped def io_read: () -> untyped def io_select: () -> untyped def io_wait: () -> untyped def io_write: () -> untyped def kernel_sleep: () -> untyped def load: () -> untyped def process_fork: () -> untyped def process_wait: () -> untyped def push: () -> untyped def raise: () -> untyped def resume: () -> untyped def run: () -> untyped def run_loop: () -> untyped def run_once: () -> untyped def run_once!: () -> untyped def scheduler_close: () -> untyped def stop: () -> untyped def terminate: () -> untyped def timeout_after: () -> untyped def to_s: () -> untyped def transfer: () -> untyped def unblock: () -> untyped def with_timeout: () -> untyped def yield: () -> untyped end # sig/async/scheduler.rbs class Async::Scheduler::ClosedError < Async::Scheduler::RuntimeError def initialize: () -> void end # sig/async/scheduler.rbs class Async::Scheduler::FiberInterrupt def alive?: () -> untyped def initialize: () -> void def transfer: () -> untyped end # sig/async/semaphore.rbs class Async::Semaphore def acquire: () -> untyped def async: () -> untyped def blocking?: () -> untyped def empty?: () -> untyped def initialize: () -> void def limit=: () -> untyped def release: () -> untyped def wait: () -> untyped end # sig/async/semaphore.rbs class Async::Semaphore::FiberNode < Async::Semaphore::List::Node def initialize: () -> void def resume: () -> untyped end # sig/async/stop.rbs class Async::Stop < Async::Exception def cause: () -> untyped def initialize: () -> void end # sig/async/stop.rbs class Async::Stop::Cause < Async::Stop::Exception def self.backtrace: () -> untyped def self.backtrace: () -> untyped def self.for: () -> untyped end # sig/async/stop.rbs class Async::Stop::Later def alive?: () -> untyped def initialize: () -> void def transfer: () -> untyped end # sig/async/task.rbs class Async::Task < Async::Node def self.current: () -> untyped def self.current?: () -> untyped def self.run: () -> untyped def self.yield: () -> untyped def alive?: () -> untyped def annotate: () -> untyped def annotation: () -> untyped def async: () -> untyped def backtrace: () -> untyped def complete?: () -> untyped def completed!: () -> untyped def completed?: () -> untyped def current?: () -> untyped def defer_stop: () -> untyped def failed!: () -> untyped def failed?: () -> untyped def finish!: () -> untyped def finished?: () -> untyped def initialize: () -> void def reactor: () -> untyped def result: () -> untyped def run: () -> untyped def running?: () -> untyped def schedule: () -> untyped def sleep: () -> untyped def status: () -> untyped def stop: () -> untyped def stop!: () -> untyped def stop_deferred?: () -> untyped def stopped!: () -> untyped def stopped?: () -> untyped def to_s: () -> untyped def wait: () -> untyped def wait_all: () -> untyped def warn: () -> untyped def with_timeout: () -> untyped def yield: () -> untyped end # sig/async/task.rbs class Async::Task::FinishedError < Async::Task::RuntimeError def initialize: () -> void end # sig/async/timeout.rbs class Async::Timeout def adjust: () -> untyped def cancel!: () -> untyped def cancelled?: () -> untyped def duration: () -> untyped def duration=: () -> untyped def initialize: () -> void def now: () -> untyped def reschedule: () -> untyped def time: () -> untyped def time=: () -> untyped end # sig/async/task.rbs class Async::TimeoutError < Async::StandardError def initialize: () -> void end # sig/async/variable.rbs class Async::Variable def initialize: () -> void def resolve: () -> untyped def resolved?: () -> untyped def value: () -> untyped def value=: () -> untyped def wait: () -> untyped end # sig/async/waiter.rbs class Async::Waiter def async: () -> untyped def first: () -> untyped def initialize: () -> void def wait: () -> untyped end # sig/async/console.rbs module Async::Console def self.debug: () -> untyped def self.error: () -> untyped def self.fatal: () -> untyped def self.info: () -> untyped def self.warn: () -> untyped end # sig/async/deadline.rbs module Async::Deadline::Zero def self.expired?: () -> untyped def self.remaining: () -> untyped end # sig/async/fork_handler.rbs module Async::ForkHandler def _fork: () -> untyped end # sig/async/scheduler.rbs module Async::Scheduler::BlockingOperationWait def blocking_operation_wait: () -> untyped end # sig/kernel/async.rbs module Kernel def Async: () -> untyped def Barrier: () -> untyped def Sync: () -> untyped end