Table of Contents - concurrent-ruby-edge-0.2.3 Documentation
Pages
- LICENSE
-
README
- Concurrent Ruby
- Supported Ruby versions
- Thread Safety
- Features & Documentation
- General-purpose Concurrency Abstractions
- Thread-safe Value Objects, Structures, and Collections
- Java-inspired ThreadPools and Other Executors
- Thread Synchronization Classes and Algorithms
- Edge Features
- Statuses:
- Usage
- Installation
- Edge Gem Installation
- C Extensions for MRI
- Note For gem developers
- Maintainers
- Special Thanks
- License and Copyright
Classes and Modules
- Concurrent
- Concurrent::Actor
- Concurrent::Actor::AbstractContext
- Concurrent::Actor::ActorTerminated
- Concurrent::Actor::Behaviour
- Concurrent::Actor::Behaviour::Abstract
- Concurrent::Actor::Behaviour::Awaits
- Concurrent::Actor::Behaviour::Buffer
- Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage
- Concurrent::Actor::Behaviour::ExecutesContext
- Concurrent::Actor::Behaviour::Linking
- Concurrent::Actor::Behaviour::Pausing
- Concurrent::Actor::Behaviour::RemovesChild
- Concurrent::Actor::Behaviour::SetResults
- Concurrent::Actor::Behaviour::Supervising
- Concurrent::Actor::Behaviour::Termination
- Concurrent::Actor::Context
- Concurrent::Actor::Core
- Concurrent::Actor::DefaultDeadLetterHandler
- Concurrent::Actor::Envelope
- Concurrent::Actor::InternalDelegations
- Concurrent::Actor::PublicDelegations
- Concurrent::Actor::Reference
- Concurrent::Actor::RestartingContext
- Concurrent::Actor::Root
- Concurrent::Actor::TypeCheck
- Concurrent::Actor::UnknownMessage
- Concurrent::Actor::Utils
- Concurrent::Actor::Utils::AdHoc
- Concurrent::Actor::Utils::AsAdHoc
- Concurrent::Actor::Utils::Balancer
- Concurrent::Actor::Utils::Broadcast
- Concurrent::Actor::Utils::Pool
- Concurrent::Channel
- Concurrent::Channel::Buffer
- Concurrent::Channel::Buffer::Base
- Concurrent::Channel::Buffer::Buffered
- Concurrent::Channel::Buffer::Dropping
- Concurrent::Channel::Buffer::Sliding
- Concurrent::Channel::Buffer::Ticker
- Concurrent::Channel::Buffer::Timer
- Concurrent::Channel::Buffer::Unbuffered
- Concurrent::Channel::Selector
- Concurrent::Channel::Selector::AfterClause
- Concurrent::Channel::Selector::DefaultClause
- Concurrent::Channel::Selector::ErrorClause
- Concurrent::Channel::Selector::PutClause
- Concurrent::Channel::Selector::TakeClause
- Concurrent::Channel::Tick
- Concurrent::Channel::ValidationError
- Concurrent::Edge
- Concurrent::Edge::AbstractPromise
- Concurrent::Edge::AnyCompletePromise
- Concurrent::Edge::AnySuccessfulPromise
- Concurrent::Edge::AtomicMarkableReference
- Concurrent::Edge::AtomicMarkableReference::ImmutableArray
- Concurrent::Edge::BlockedPromise
- Concurrent::Edge::BlockedTaskPromise
- Concurrent::Edge::ChainPromise
- Concurrent::Edge::CompletableEvent
- Concurrent::Edge::CompletableEventPromise
- Concurrent::Edge::CompletableFuture
- Concurrent::Edge::CompletableFuturePromise
- Concurrent::Edge::DelayPromise
- Concurrent::Edge::Event
- Concurrent::Edge::Event::Completed
- Concurrent::Edge::Event::Pending
- Concurrent::Edge::Event::State
- Concurrent::Edge::EventWrapperPromise
- Concurrent::Edge::FlatPromise
- Concurrent::Edge::Future
- Concurrent::Edge::Future::CompletedWithResult
- Concurrent::Edge::Future::Failed
- Concurrent::Edge::Future::PartiallyFailed
- Concurrent::Edge::Future::Success
- Concurrent::Edge::Future::SuccessArray
- Concurrent::Edge::FutureShortcuts
- Concurrent::Edge::FutureWrapperPromise
- Concurrent::Edge::ImmediateEventPromise
- Concurrent::Edge::ImmediateFuturePromise
- Concurrent::Edge::InnerPromise
- Concurrent::Edge::LockFreeLinkedSet
- Concurrent::Edge::LockFreeLinkedSet::Head
- Concurrent::Edge::LockFreeLinkedSet::Node
- Concurrent::Edge::LockFreeLinkedSet::Tail
- Concurrent::Edge::LockFreeLinkedSet::Window
- Concurrent::Edge::LockFreeStack
- Concurrent::Edge::LockFreeStack::Empty
- Concurrent::Edge::LockFreeStack::Node
- Concurrent::Edge::RescuePromise
- Concurrent::Edge::ScheduledPromise
- Concurrent::Edge::ThenPromise
- Concurrent::Edge::ZipEventEventPromise
- Concurrent::Edge::ZipEventsPromise
- Concurrent::Edge::ZipFutureEventPromise
- Concurrent::Edge::ZipFutureFuturePromise
- Concurrent::Edge::ZipFuturesPromise
Methods
- ::after — Concurrent::Channel
- ::alt — Concurrent::Channel
- ::base — Concurrent::Actor::Behaviour
- ::basic_behaviour_definition — Concurrent::Actor::Behaviour
- ::current — Concurrent::Actor
- ::error — Concurrent::Actor::TypeCheck
- ::find — Concurrent::Edge::LockFreeLinkedSet::Window
- ::go — Concurrent::Channel
- ::go_loop — Concurrent::Channel
- ::go_loop_via — Concurrent::Channel
- ::go_via — Concurrent::Channel
- ::linking — Concurrent::Actor::Behaviour
- ::new — Concurrent::Actor::Behaviour::Abstract
- ::new — Concurrent::Actor::Behaviour::Buffer
- ::new — Concurrent::Actor::Behaviour::Linking
- ::new — Concurrent::Actor::Behaviour::Pausing
- ::new — Concurrent::Actor::Behaviour::SetResults
- ::new — Concurrent::Actor::Behaviour::Supervising
- ::new — Concurrent::Actor::Behaviour::Termination
- ::new — Concurrent::Actor::Core
- ::new — Concurrent::Actor::Envelope
- ::new — Concurrent::Actor::ActorTerminated
- ::new — Concurrent::Actor::UnknownMessage
- ::new — Concurrent::Actor::Reference
- ::new — Concurrent::Actor::Root
- ::new — Concurrent::Actor::Utils::Balancer
- ::new — Concurrent::Actor::Utils::Broadcast
- ::new — Concurrent::Actor::Utils::Pool
- ::new — Concurrent::Channel
- ::new — Concurrent::Channel::ValidationError
- ::new — Concurrent::Channel::Buffer::Base
- ::new — Concurrent::Channel::Selector
- ::new — Concurrent::Channel::Selector::AfterClause
- ::new — Concurrent::Channel::Selector::DefaultClause
- ::new — Concurrent::Channel::Selector::ErrorClause
- ::new — Concurrent::Channel::Selector::PutClause
- ::new — Concurrent::Channel::Selector::TakeClause
- ::new — Concurrent::Channel::Tick
- ::new — Concurrent::Edge::AtomicMarkableReference
- ::new — Concurrent::Edge::AtomicMarkableReference::ImmutableArray
- ::new — Concurrent::Edge::Event
- ::new — Concurrent::Edge::Future::Success
- ::new — Concurrent::Edge::Future::Failed
- ::new — Concurrent::Edge::Future::PartiallyFailed
- ::new — Concurrent::Edge::AbstractPromise
- ::new — Concurrent::Edge::CompletableEventPromise
- ::new — Concurrent::Edge::CompletableFuturePromise
- ::new — Concurrent::Edge::BlockedPromise
- ::new — Concurrent::Edge::BlockedPromise
- ::new — Concurrent::Edge::BlockedTaskPromise
- ::new — Concurrent::Edge::ThenPromise
- ::new — Concurrent::Edge::RescuePromise
- ::new — Concurrent::Edge::ImmediateEventPromise
- ::new — Concurrent::Edge::ImmediateFuturePromise
- ::new — Concurrent::Edge::FlatPromise
- ::new — Concurrent::Edge::ZipEventEventPromise
- ::new — Concurrent::Edge::ZipFutureEventPromise
- ::new — Concurrent::Edge::ZipFutureFuturePromise
- ::new — Concurrent::Edge::EventWrapperPromise
- ::new — Concurrent::Edge::FutureWrapperPromise
- ::new — Concurrent::Edge::ZipFuturesPromise
- ::new — Concurrent::Edge::ZipEventsPromise
- ::new — Concurrent::Edge::AnyCompletePromise
- ::new — Concurrent::Edge::AnySuccessfulPromise
- ::new — Concurrent::Edge::DelayPromise
- ::new — Concurrent::Edge::ScheduledPromise
- ::new — Concurrent::Edge::LockFreeLinkedSet
- ::new — Concurrent::Edge::LockFreeLinkedSet::Node
- ::new — Concurrent::Edge::LockFreeLinkedSet::Tail
- ::new — Concurrent::Edge::LockFreeLinkedSet::Window
- ::new — Concurrent::Edge::LockFreeStack
- ::new — Concurrent::Edge::LockFreeStack::Node
- ::new — Concurrent::Actor::Utils::AsAdHoc
- ::restarting_behaviour_definition — Concurrent::Actor::Behaviour
- ::root — Concurrent::Actor
- ::select — Concurrent::Channel
- ::spawn — Concurrent::Actor::AbstractContext
- ::spawn — Concurrent::Actor
- ::spawn! — Concurrent::Actor::AbstractContext
- ::spawn! — Concurrent::Actor
- ::supervised — Concurrent::Actor::Behaviour
- ::supervising — Concurrent::Actor::Behaviour
- ::tick — Concurrent::Channel
- ::ticker — Concurrent::Channel
- ::timer — Concurrent::Channel
- ::to_spawn_options — Concurrent::Actor::AbstractContext
- ::to_spawn_options — Concurrent::Actor
- ::user_messages — Concurrent::Actor::Behaviour
- #& — Concurrent::Edge::Event
- #& — Concurrent::Edge::Future
- #<< — Concurrent::Actor::AbstractContext
- #<< — Concurrent::Actor::Reference
- #<< — Concurrent::Channel
- #<< — Concurrent::Edge::LockFreeLinkedSet
- #<=> — Concurrent::Channel::Tick
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Node
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Tail
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Head
- #== — Concurrent::Actor::Reference
- #Child! — Concurrent::Actor::TypeCheck
- #Child? — Concurrent::Actor::TypeCheck
- #Match! — Concurrent::Actor::TypeCheck
- #Match? — Concurrent::Actor::TypeCheck
- #Type! — Concurrent::Actor::TypeCheck
- #Type? — Concurrent::Actor::TypeCheck
- #actor_class — Concurrent::Actor::PublicDelegations
- #add — Concurrent::Edge::LockFreeLinkedSet
- #add_callback — Concurrent::Edge::Event
- #add_callback — Concurrent::Edge::Future
- #add_child — Concurrent::Actor::Core
- #address_path — Concurrent::Actor::Envelope
- #after — Concurrent::Channel::Selector
- #allocate_context — Concurrent::Actor::Core
- #any — Concurrent::Edge::Future
- #any — Concurrent::Edge::FutureShortcuts
- #any_complete — Concurrent::Edge::FutureShortcuts
- #any_successful — Concurrent::Edge::FutureShortcuts
- #apply — Concurrent::Edge::Future
- #apply — Concurrent::Edge::Future::Success
- #apply — Concurrent::Edge::Future::SuccessArray
- #apply — Concurrent::Edge::Future::Failed
- #apply — Concurrent::Edge::Future::PartiallyFailed
- #ask — Concurrent::Actor::AbstractContext
- #ask — Concurrent::Actor::Reference
- #ask! — Concurrent::Actor::AbstractContext
- #ask! — Concurrent::Actor::Reference
- #async — Concurrent::Edge::FutureShortcuts
- #async_callback_on_completion — Concurrent::Edge::Event
- #async_callback_on_completion — Concurrent::Edge::Future
- #async_callback_on_failure — Concurrent::Edge::Future
- #async_callback_on_success — Concurrent::Edge::Future
- #behaviour — Concurrent::Actor::Core
- #behaviour — Concurrent::Actor::InternalDelegations
- #behaviour! — Concurrent::Actor::Core
- #behaviour! — Concurrent::Actor::InternalDelegations
- #behaviour_definition — Concurrent::Actor::AbstractContext
- #behaviour_definition — Concurrent::Actor::Context
- #behaviour_definition — Concurrent::Actor::RestartingContext
- #behaviour_definition — Concurrent::Actor::Root
- #blocked_by — Concurrent::Edge::BlockedPromise
- #blocked_by — Concurrent::Edge::FlatPromise
- #blocking? — Concurrent::Channel::Buffer::Base
- #blocking? — Concurrent::Channel::Buffer::Dropping
- #blocking? — Concurrent::Channel::Buffer::Sliding
- #blocks — Concurrent::Edge::Event
- #broadcast — Concurrent::Actor::Behaviour::Abstract
- #broadcast — Concurrent::Actor::Core
- #buffer — Concurrent::Channel
- #buffer — Concurrent::Channel::Buffer::Base
- #buffer= — Concurrent::Channel
- #buffer= — Concurrent::Channel::Buffer::Base
- #build_context — Concurrent::Actor::Core
- #call_callback — Concurrent::Edge::Event
- #call_callback — Concurrent::Edge::Future
- #call_callbacks — Concurrent::Edge::Event
- #call_callbacks — Concurrent::Edge::Future
- #callback_notify_blocked — Concurrent::Edge::Event
- #callback_notify_blocked — Concurrent::Edge::Future
- #callback_on_completion — Concurrent::Edge::Event
- #callback_on_completion — Concurrent::Edge::Future
- #callback_on_failure — Concurrent::Edge::Future
- #callback_on_success — Concurrent::Edge::Future
- #callbacks — Concurrent::Edge::Event
- #capacity= — Concurrent::Channel::Buffer::Base
- #case — Concurrent::Channel::Selector
- #chain — Concurrent::Edge::Event
- #chain_completable — Concurrent::Edge::Event
- #chain_completable — Concurrent::Edge::Future
- #children — Concurrent::Actor::Core
- #children — Concurrent::Actor::InternalDelegations
- #clear — Concurrent::Edge::LockFreeStack
- #clear_blocked_by! — Concurrent::Edge::BlockedPromise
- #clear_blocked_by! — Concurrent::Edge::FlatPromise
- #clear_each — Concurrent::Edge::LockFreeStack
- #close — Concurrent::Channel::Buffer::Base
- #closed= — Concurrent::Channel::Buffer::Base
- #closed? — Concurrent::Channel::Buffer::Base
- #compare_and_clear — Concurrent::Edge::LockFreeStack
- #compare_and_pop — Concurrent::Edge::LockFreeStack
- #compare_and_push — Concurrent::Edge::LockFreeStack
- #compare_and_set — Concurrent::Edge::AtomicMarkableReference
- #compare_and_swap — Concurrent::Edge::AtomicMarkableReference
- #completable? — Concurrent::Edge::BlockedPromise
- #completable? — Concurrent::Edge::FlatPromise
- #completable? — Concurrent::Edge::AnyCompletePromise
- #completable? — Concurrent::Edge::AnySuccessfulPromise
- #complete — Concurrent::Edge::CompletableEvent
- #complete — Concurrent::Edge::CompletableFuture
- #complete? — Concurrent::Edge::Event
- #complete_with — Concurrent::Edge::Event
- #complete_with — Concurrent::Edge::Future
- #complete_with — Concurrent::Edge::AbstractPromise
- #completed? — Concurrent::Edge::Event
- #completed? — Concurrent::Edge::Event::State
- #completed? — Concurrent::Edge::Event::Pending
- #completed? — Concurrent::Edge::Event::Completed
- #completed_event — Concurrent::Edge::FutureShortcuts
- #completed_future — Concurrent::Edge::FutureShortcuts
- #contains? — Concurrent::Edge::LockFreeLinkedSet
- #context — Concurrent::Actor::InternalDelegations
- #context_class — Concurrent::Actor::PublicDelegations
- #data — Concurrent::Edge::LockFreeLinkedSet::Node
- #dead_letter_routing — Concurrent::Actor::AbstractContext
- #dead_letter_routing — Concurrent::Actor::Core
- #dead_letter_routing — Concurrent::Actor::Reference
- #dead_letter_routing — Concurrent::Actor::Root
- #dead_letter_routing — Concurrent::Actor::InternalDelegations
- #default — Concurrent::Channel::Selector
- #default_executor — Concurrent::Actor::AbstractContext
- #default_executor — Concurrent::Edge::Event
- #default_executor — Concurrent::Edge::AbstractPromise
- #default_reference_class — Concurrent::Actor::AbstractContext
- #delay — Concurrent::Edge::Event
- #delay — Concurrent::Edge::Future
- #delay — Concurrent::Edge::FutureShortcuts
- #distribute — Concurrent::Actor::Utils::Balancer
- #do_next — Concurrent::Channel
- #do_offer — Concurrent::Channel
- #do_pause — Concurrent::Actor::Behaviour::Pausing
- #do_poll — Concurrent::Channel
- #do_poll — Concurrent::Channel::Buffer::Ticker
- #do_poll — Concurrent::Channel::Buffer::Timer
- #do_put — Concurrent::Channel
- #do_reset — Concurrent::Actor::Behaviour::Pausing
- #do_restart — Concurrent::Actor::Behaviour::Pausing
- #do_resume — Concurrent::Actor::Behaviour::Pausing
- #do_take — Concurrent::Channel
- #each — Concurrent::Channel
- #each — Concurrent::Edge::LockFreeLinkedSet
- #each — Concurrent::Edge::LockFreeStack
- #empty? — Concurrent::Channel::Buffer::Base
- #empty? — Concurrent::Channel::Buffer::Unbuffered
- #empty? — Concurrent::Edge::LockFreeStack
- #envelope — Concurrent::Actor::AbstractContext
- #epoch — Concurrent::Channel::Tick
- #error — Concurrent::Channel::Selector
- #evaluate_to — Concurrent::Edge::CompletableFuture
- #evaluate_to — Concurrent::Edge::AbstractPromise
- #evaluate_to! — Concurrent::Edge::CompletableFuture
- #evaluate_to! — Concurrent::Edge::CompletableFuturePromise
- #event — Concurrent::Edge::AbstractPromise
- #event — Concurrent::Edge::FutureShortcuts
- #exception — Concurrent::Edge::Future
- #execute — Concurrent::Channel::Selector
- #execute — Concurrent::Channel::Selector::AfterClause
- #execute — Concurrent::Channel::Selector::DefaultClause
- #execute — Concurrent::Channel::Selector::ErrorClause
- #execute — Concurrent::Channel::Selector::PutClause
- #execute — Concurrent::Channel::Selector::TakeClause
- #executor — Concurrent::Edge::BlockedTaskPromise
- #executor — Concurrent::Actor::PublicDelegations
- #fail — Concurrent::Edge::CompletableFuture
- #fail — Concurrent::Edge::CompletableFuturePromise
- #failed? — Concurrent::Edge::Future
- #failed_future — Concurrent::Edge::FutureShortcuts
- #filtered_receivers — Concurrent::Actor::Utils::Broadcast
- #flat — Concurrent::Edge::Future
- #fulfilled? — Concurrent::Edge::Future
- #full? — Concurrent::Channel::Buffer::Base
- #full? — Concurrent::Channel::Buffer::Unbuffered
- #future — Concurrent::Edge::AbstractPromise
- #future — Concurrent::Edge::FutureShortcuts
- #get — Concurrent::Edge::AtomicMarkableReference
- #guard! — Concurrent::Actor::Core
- #hide_completable — Concurrent::Edge::CompletableEvent
- #hide_completable — Concurrent::Edge::CompletableFuture
- #incomplete? — Concurrent::Edge::Event
- #initialize_behaviours — Concurrent::Actor::Core
- #initialize_blocked_by — Concurrent::Edge::BlockedPromise
- #initialize_blocked_by — Concurrent::Edge::FlatPromise
- #initialize_core — Concurrent::Actor::AbstractContext
- #inspect — Concurrent::Actor::Reference
- #inspect — Concurrent::Edge::Event
- #inspect — Concurrent::Edge::AbstractPromise
- #inspect — Concurrent::Edge::BlockedPromise
- #inspect — Concurrent::Edge::ScheduledPromise
- #intended_time — Concurrent::Edge::ScheduledPromise
- #key — Concurrent::Edge::LockFreeLinkedSet::Node
- #key_for — Concurrent::Edge::LockFreeLinkedSet::Node
- #last? — Concurrent::Edge::LockFreeLinkedSet::Node
- #link — Concurrent::Actor::Behaviour::Linking
- #log — Concurrent::Actor::Core
- #log — Concurrent::Actor::InternalDelegations
- #map — Concurrent::Actor::Reference
- #mark — Concurrent::Edge::AtomicMarkableReference
- #marked? — Concurrent::Edge::AtomicMarkableReference
- #message — Concurrent::Actor::Reference
- #monotonic_to_utc — Concurrent::Channel::Tick
- #name — Concurrent::Actor::PublicDelegations
- #next — Concurrent::Channel
- #next — Concurrent::Channel::Buffer::Base
- #next — Concurrent::Channel::Buffer::Buffered
- #next — Concurrent::Channel::Buffer::Timer
- #next — Concurrent::Channel::Buffer::Unbuffered
- #next? — Concurrent::Channel
- #next_node — Concurrent::Edge::LockFreeLinkedSet::Node
- #next_node — Concurrent::Edge::LockFreeStack::Empty
- #ns_closed? — Concurrent::Channel::Buffer::Base
- #ns_empty? — Concurrent::Channel::Buffer::Base
- #ns_empty? — Concurrent::Channel::Buffer::Buffered
- #ns_empty? — Concurrent::Channel::Buffer::Timer
- #ns_full? — Concurrent::Channel::Buffer::Base
- #ns_full? — Concurrent::Channel::Buffer::Buffered
- #ns_full? — Concurrent::Channel::Buffer::Dropping
- #ns_full? — Concurrent::Channel::Buffer::Sliding
- #ns_full? — Concurrent::Channel::Buffer::Timer
- #ns_initialize — Concurrent::Actor::Core
- #ns_initialize — Concurrent::Channel::Buffer::Base
- #ns_initialize — Concurrent::Channel::Buffer::Buffered
- #ns_initialize — Concurrent::Channel::Buffer::Ticker
- #ns_initialize — Concurrent::Channel::Buffer::Timer
- #ns_initialize — Concurrent::Channel::Buffer::Unbuffered
- #ns_put_onto_buffer — Concurrent::Channel::Buffer::Buffered
- #ns_put_onto_buffer — Concurrent::Channel::Buffer::Dropping
- #ns_put_onto_buffer — Concurrent::Channel::Buffer::Sliding
- #ns_size — Concurrent::Channel::Buffer::Base
- #ns_size — Concurrent::Channel::Buffer::Buffered
- #ns_size — Concurrent::Channel::Buffer::Timer
- #offer — Concurrent::Channel
- #offer — Concurrent::Channel::Buffer::Base
- #offer — Concurrent::Channel::Buffer::Buffered
- #offer — Concurrent::Channel::Buffer::Timer
- #offer — Concurrent::Channel::Buffer::Unbuffered
- #offer! — Concurrent::Channel
- #offer? — Concurrent::Channel
- #on_completable — Concurrent::Edge::BlockedPromise
- #on_completable — Concurrent::Edge::ThenPromise
- #on_completable — Concurrent::Edge::RescuePromise
- #on_completable — Concurrent::Edge::ChainPromise
- #on_completable — Concurrent::Edge::FlatPromise
- #on_completable — Concurrent::Edge::ZipEventEventPromise
- #on_completable — Concurrent::Edge::ZipFutureEventPromise
- #on_completable — Concurrent::Edge::ZipFutureFuturePromise
- #on_completable — Concurrent::Edge::EventWrapperPromise
- #on_completable — Concurrent::Edge::FutureWrapperPromise
- #on_completable — Concurrent::Edge::ZipFuturesPromise
- #on_completable — Concurrent::Edge::ZipEventsPromise
- #on_completable — Concurrent::Edge::AnyCompletePromise
- #on_completable — Concurrent::Edge::AnySuccessfulPromise
- #on_completion — Concurrent::Edge::Event
- #on_completion! — Concurrent::Edge::Event
- #on_done — Concurrent::Edge::BlockedPromise
- #on_envelope — Concurrent::Actor::Behaviour::Abstract
- #on_envelope — Concurrent::Actor::Behaviour::Awaits
- #on_envelope — Concurrent::Actor::Behaviour::Buffer
- #on_envelope — Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage
- #on_envelope — Concurrent::Actor::Behaviour::ExecutesContext
- #on_envelope — Concurrent::Actor::Behaviour::Linking
- #on_envelope — Concurrent::Actor::Behaviour::Pausing
- #on_envelope — Concurrent::Actor::Behaviour::RemovesChild
- #on_envelope — Concurrent::Actor::Behaviour::SetResults
- #on_envelope — Concurrent::Actor::Behaviour::Supervising
- #on_envelope — Concurrent::Actor::Behaviour::Termination
- #on_envelope — Concurrent::Actor::AbstractContext
- #on_envelope — Concurrent::Actor::Core
- #on_event — Concurrent::Actor::Behaviour::Abstract
- #on_event — Concurrent::Actor::Behaviour::Buffer
- #on_event — Concurrent::Actor::Behaviour::ExecutesContext
- #on_event — Concurrent::Actor::Behaviour::Linking
- #on_event — Concurrent::Actor::Behaviour::Pausing
- #on_event — Concurrent::Actor::AbstractContext
- #on_failure — Concurrent::Edge::Future
- #on_failure! — Concurrent::Edge::Future
- #on_message — Concurrent::Actor::AbstractContext
- #on_message — Concurrent::Actor::DefaultDeadLetterHandler
- #on_message — Concurrent::Actor::Root
- #on_message — Concurrent::Actor::Utils::Balancer
- #on_message — Concurrent::Actor::Utils::Broadcast
- #on_message — Concurrent::Actor::Utils::Pool
- #on_message — Concurrent::Actor::Utils::AsAdHoc
- #on_success — Concurrent::Edge::Future
- #on_success! — Concurrent::Edge::Future
- #parent — Concurrent::Actor::Core
- #parent — Concurrent::Actor::PublicDelegations
- #pass — Concurrent::Actor::Behaviour::Abstract
- #pass — Concurrent::Actor::AbstractContext
- #path — Concurrent::Actor::PublicDelegations
- #pause! — Concurrent::Actor::Behaviour::Pausing
- #paused? — Concurrent::Actor::Behaviour::Pausing
- #peek — Concurrent::Edge::LockFreeStack
- #pending? — Concurrent::Edge::Event
- #poll — Concurrent::Channel
- #poll — Concurrent::Channel::Buffer::Base
- #poll — Concurrent::Channel::Buffer::Buffered
- #poll — Concurrent::Channel::Buffer::Timer
- #poll — Concurrent::Channel::Buffer::Unbuffered
- #poll! — Concurrent::Channel
- #poll? — Concurrent::Channel
- #pop — Concurrent::Edge::LockFreeStack
- #post — Concurrent::Edge::FutureShortcuts
- #post! — Concurrent::Edge::FutureShortcuts
- #post_on — Concurrent::Edge::FutureShortcuts
- #process_envelope — Concurrent::Actor::Behaviour::Buffer
- #process_envelope — Concurrent::Actor::Core
- #process_envelopes? — Concurrent::Actor::Behaviour::Buffer
- #process_on_done — Concurrent::Edge::BlockedPromise
- #process_on_done — Concurrent::Edge::FlatPromise
- #promise — Concurrent::Edge::Event
- #push — Concurrent::Edge::LockFreeStack
- #put — Concurrent::Channel
- #put — Concurrent::Channel::Buffer::Base
- #put — Concurrent::Channel::Buffer::Buffered
- #put — Concurrent::Channel::Buffer::Timer
- #put — Concurrent::Channel::Buffer::Unbuffered
- #put — Concurrent::Channel::Selector
- #put! — Concurrent::Channel
- #put? — Concurrent::Channel
- #putting — Concurrent::Channel::Buffer::Unbuffered
- #reason — Concurrent::Edge::Future
- #reason — Concurrent::Edge::Future::CompletedWithResult
- #reason — Concurrent::Edge::Future::Success
- #reason — Concurrent::Edge::Future::Failed
- #reason — Concurrent::Edge::Future::PartiallyFailed
- #rebuild_context — Concurrent::Actor::Behaviour::Pausing
- #receive — Concurrent::Channel
- #receive — Concurrent::Channel::Selector
- #redirect — Concurrent::Actor::InternalDelegations
- #ref — Concurrent::Actor::PublicDelegations
- #reference — Concurrent::Actor::PublicDelegations
- #reject! — Concurrent::Actor::Envelope
- #reject_deferred — Concurrent::Actor::Behaviour::Pausing
- #reject_envelope — Concurrent::Actor::Behaviour::Abstract
- #rejected? — Concurrent::Edge::Future
- #remove — Concurrent::Edge::LockFreeLinkedSet
- #remove_child — Concurrent::Actor::Core
- #reschedule_deferred — Concurrent::Actor::Behaviour::Pausing
- #rescue — Concurrent::Edge::Future
- #reset! — Concurrent::Actor::Behaviour::Pausing
- #restart! — Concurrent::Actor::Behaviour::Pausing
- #result — Concurrent::Edge::Future
- #result — Concurrent::Edge::Future::CompletedWithResult
- #resume! — Concurrent::Actor::Behaviour::Pausing
- #schedule — Concurrent::Edge::Future
- #schedule — Concurrent::Edge::FutureShortcuts
- #schedule_execution — Concurrent::Actor::Core
- #select — Concurrent::Edge::FutureShortcuts
- #send — Concurrent::Channel
- #send — Concurrent::Channel::Selector
- #sender_path — Concurrent::Actor::Envelope
- #set — Concurrent::Edge::AtomicMarkableReference
- #set — Concurrent::Edge::Event
- #size — Concurrent::Channel::Buffer::Base
- #size — Concurrent::Channel::Buffer::Unbuffered
- #size= — Concurrent::Channel::Buffer::Base
- #state — Concurrent::Edge::Event
- #state — Concurrent::Edge::AbstractPromise
- #succeeded_future — Concurrent::Edge::FutureShortcuts
- #success — Concurrent::Edge::CompletableFuture
- #success — Concurrent::Edge::CompletableFuturePromise
- #success? — Concurrent::Edge::Future
- #success? — Concurrent::Edge::Future::CompletedWithResult
- #success? — Concurrent::Edge::Future::Success
- #success? — Concurrent::Edge::Future::Failed
- #success? — Concurrent::Edge::Future::PartiallyFailed
- #successor_reference — Concurrent::Edge::LockFreeLinkedSet::Node
- #take — Concurrent::Channel
- #take — Concurrent::Channel::Buffer::Base
- #take — Concurrent::Channel::Buffer::Buffered
- #take — Concurrent::Channel::Buffer::Timer
- #take — Concurrent::Channel::Buffer::Unbuffered
- #take — Concurrent::Channel::Selector
- #take! — Concurrent::Channel
- #take? — Concurrent::Channel
- #taking — Concurrent::Channel::Buffer::Unbuffered
- #tangle — Concurrent::Edge::Event
- #tangle — Concurrent::Edge::Future
- #tell — Concurrent::Actor::AbstractContext
- #tell — Concurrent::Actor::Reference
- #terminate! — Concurrent::Actor::Behaviour::Termination
- #terminate! — Concurrent::Actor::InternalDelegations
- #terminated? — Concurrent::Actor::Behaviour::Termination
- #terminated? — Concurrent::Actor::InternalDelegations
- #then — Concurrent::Edge::Event
- #then — Concurrent::Edge::Future
- #then_ask — Concurrent::Edge::Future
- #then_put — Concurrent::Edge::Future
- #then_select — Concurrent::Edge::Event
- #then_select — Concurrent::Edge::Future
- #timeout — Concurrent::Channel::Selector
- #to_s — Concurrent::Actor::Reference
- #to_s — Concurrent::Channel::Tick
- #to_s — Concurrent::Edge::Event
- #to_s — Concurrent::Edge::AbstractPromise
- #to_sym — Concurrent::Edge::Event::State
- #to_sym — Concurrent::Edge::Event::Pending
- #to_sym — Concurrent::Edge::Event::Completed
- #to_sym — Concurrent::Edge::Future::Success
- #to_sym — Concurrent::Edge::Future::Failed
- #to_sym — Concurrent::Edge::Future::PartiallyFailed
- #touch — Concurrent::Edge::Event
- #touch — Concurrent::Edge::AbstractPromise
- #touch — Concurrent::Edge::BlockedPromise
- #touch — Concurrent::Edge::DelayPromise
- #touched — Concurrent::Edge::Event
- #trapping= — Concurrent::Actor::Behaviour::Termination
- #trapping? — Concurrent::Actor::Behaviour::Termination
- #try_fail — Concurrent::Edge::CompletableFuture
- #try_fail — Concurrent::Edge::CompletableFuturePromise
- #try_success — Concurrent::Edge::CompletableFuture
- #try_success — Concurrent::Edge::CompletableFuturePromise
- #try_update — Concurrent::Edge::AtomicMarkableReference
- #try_update! — Concurrent::Edge::AtomicMarkableReference
- #unlink — Concurrent::Actor::Behaviour::Linking
- #unscheduled? — Concurrent::Edge::Event
- #update — Concurrent::Edge::AtomicMarkableReference
- #validate — Concurrent::Channel
- #validator — Concurrent::Channel
- #validator= — Concurrent::Channel
- #value — Concurrent::Edge::AtomicMarkableReference
- #value — Concurrent::Edge::Future
- #value — Concurrent::Edge::Future::CompletedWithResult
- #value — Concurrent::Edge::Future::Success
- #value — Concurrent::Edge::Future::Failed
- #value — Concurrent::Edge::Future::PartiallyFailed
- #value! — Concurrent::Edge::Future
- #wait — Concurrent::Edge::Event
- #wait! — Concurrent::Edge::Future
- #wait_until_complete — Concurrent::Edge::Event
- #wait_until_complete! — Concurrent::Edge::Future
- #waiting_threads — Concurrent::Edge::Event
- #with_async — Concurrent::Edge::Event
- #with_default_executor — Concurrent::Edge::Event
- #with_default_executor — Concurrent::Edge::Future
- #zip — Concurrent::Edge::Event
- #zip — Concurrent::Edge::Future
- #zip — Concurrent::Edge::FutureShortcuts
- #zip_events — Concurrent::Edge::FutureShortcuts
- #zip_futures — Concurrent::Edge::FutureShortcuts
- #| — Concurrent::Edge::Future
- #~ — Concurrent::Channel