Table of Contents - concurrent-ruby-edge-0.7.2 Documentation
Pages
-
CHANGELOG
- Current
- Release v1.3.5, edge v0.7.2 (15 January 2025)
- Release v1.3.4 (10 August 2024)
- Release v1.3.3 (9 June 2024)
- Release v1.3.2, edge v0.7.1 (7 June 2024)
- Release v1.3.1 (29 May 2024)
- Release v1.3.0 (28 May 2024)
- Release v1.2.3 (16 Jan 2024)
- Release v1.2.2 (24 Feb 2023)
- Release v1.2.1 (24 Feb 2023)
- Release v1.2.0 (23 Jan 2023)
- Release v1.1.10 (22 Mar 2022)
- Release v1.1.9 (5 Jun 2021)
- Release v1.1.8 (20 January 2021)
- Release v1.1.7 (6 August 2020)
- Release v1.1.6, edge v0.6.0 (10 Feb 2020)
- Release v1.1.6.pre1, edge v0.6.0.pre1 (26 Jan 2020)
- Release v1.1.5, edge v0.5.0 (10 Mar 2019)
- Release v1.1.4 (14 Dec 2018)
- Release v1.1.3 (7 Nov 2018)
- Release v1.1.2 (6 Nov 2018)
- Release v1.1.1, edge v0.4.1 (1 Nov 2018)
- Release v1.1.0, edge v0.4.0 (31 OCt 2018) (yanked)
- Release v1.1.0.pre2, edge v0.4.0.pre2 (18 Sep 2018)
- Release v1.1.0.pre1, edge v0.4.0.pre1 (15 Aug 2018)
- Release v1.0.5, edge v0.3.1 (26 Feb 2017)
- Release v1.0.4, edge v0.3.0 (27 Dec 2016)
- Release v1.0.3 (17 Dec 2016)
- Release v1.0.2 (2 May 2016)
- Release v1.0.1 (27 February 2016)
- Release v1.0.0 (13 November 2015)
- Release v0.9.1 (09 August 2015)
- Release v0.9.0 (10 July 2015)
- Release v0.8.0 (25 January 2015)
- Release v0.7.2 (24 January 2015)
- Release v0.7.1 (4 December 2014)
- Release v0.7.0 (13 August 2014)
- Release v0.6.1 (14 June 2014)
- Release v0.6.0 (25 May 2014)
- Release v0.5.0
- LICENSE
-
README
- Concurrent Ruby
- Contributing
- Thread Safety
- Features & Documentation
- Versioning
- General-purpose Concurrency Abstractions
- Thread-safe Value Objects, Structures, and Collections
- Java-inspired ThreadPools and Other Executors
- Thread Synchronization Classes and Algorithms
- Deprecated
- Edge Features
- Supported Ruby versions
- Usage
- Installation
- Edge Gem Installation
- C Extensions for MRI
- Note For gem developers
- Building the gem
- Requirements
- Publishing the Gem
- Maintainers
- Special Thanks to
- 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::Cancellation
- 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::LockFreeLinkedSet
- Concurrent::Edge::LockFreeLinkedSet::Head
- Concurrent::Edge::LockFreeLinkedSet::Node
- Concurrent::Edge::LockFreeLinkedSet::Tail
- Concurrent::Edge::LockFreeLinkedSet::Window
- Concurrent::ErlangActor
- Concurrent::ErlangActor::AbstractActor
- Concurrent::ErlangActor::AbstractSignal
- Concurrent::ErlangActor::Ask
- Concurrent::ErlangActor::DeMonitor
- Concurrent::ErlangActor::Down
- Concurrent::ErlangActor::DownSignal
- Concurrent::ErlangActor::Environment
- Concurrent::ErlangActor::EnvironmentConstants
- Concurrent::ErlangActor::EnvironmentConstants::AbstractLogicOperationMatcher
- Concurrent::ErlangActor::EnvironmentConstants::And
- Concurrent::ErlangActor::EnvironmentConstants::Or
- Concurrent::ErlangActor::Error
- Concurrent::ErlangActor::FunctionShortcuts
- Concurrent::ErlangActor::Functions
- Concurrent::ErlangActor::HasFrom
- Concurrent::ErlangActor::HasReason
- Concurrent::ErlangActor::HasReference
- Concurrent::ErlangActor::Kill
- Concurrent::ErlangActor::Link
- Concurrent::ErlangActor::Monitor
- Concurrent::ErlangActor::NoActor
- Concurrent::ErlangActor::NoReply
- Concurrent::ErlangActor::OnPool
- Concurrent::ErlangActor::OnThread
- Concurrent::ErlangActor::Pid
- Concurrent::ErlangActor::Reference
- Concurrent::ErlangActor::Run
- Concurrent::ErlangActor::Terminate
- Concurrent::ErlangActor::Terminated
- Concurrent::ErlangActor::Token
- Concurrent::ErlangActor::UnLink
- Concurrent::LazyRegister
- Concurrent::LockFreeQueue
- Concurrent::LockFreeQueue::Node
- Concurrent::ProcessingActor
- Concurrent::Promises
- Concurrent::Promises::Channel
- Concurrent::Promises::FactoryMethods
- Concurrent::Promises::FactoryMethods::OldChannelIntegration
- Concurrent::Promises::Future
- Concurrent::Promises::Future::ActorIntegration
- Concurrent::Promises::Future::FlatShortcuts
- Concurrent::Promises::Future::NewChannelIntegration
- Concurrent::Promises::Future::OldChannelIntegration
- Concurrent::Promises::Resolvable
- Concurrent::Throttle
- Concurrent::Throttle::ProxyExecutor
- Concurrent::WrappingExecutor
Methods
- ::[] — Concurrent::ErlangActor::EnvironmentConstants::AbstractLogicOperationMatcher
- ::[] — Concurrent::ErlangActor::Run
- ::act — Concurrent::ProcessingActor
- ::act_listening — Concurrent::ProcessingActor
- ::after — Concurrent::Channel
- ::alt — Concurrent::Channel
- ::atomic_resolution — Concurrent::Promises::Resolvable
- ::base — Concurrent::Actor::Behaviour
- ::basic_behaviour_definition — Concurrent::Actor::Behaviour
- ::create — Concurrent::ErlangActor
- ::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
- ::locking_order_by — Concurrent::Promises::Resolvable
- ::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::Cancellation
- ::new — Concurrent::Promises::Channel
- ::new — Concurrent::ErlangActor::Pid
- ::new — Concurrent::ErlangActor::Environment
- ::new — Concurrent::ErlangActor::Token
- ::new — Concurrent::ErlangActor::EnvironmentConstants::AbstractLogicOperationMatcher
- ::new — Concurrent::ErlangActor::Run
- ::new — Concurrent::ErlangActor::AbstractActor
- ::new — Concurrent::ErlangActor::OnPool
- ::new — Concurrent::ErlangActor::OnThread
- ::new — Concurrent::ErlangActor::Ask
- ::new — Concurrent::ErlangActor::Terminate
- ::new — Concurrent::ErlangActor::Terminated
- ::new — Concurrent::ErlangActor::DownSignal
- ::new — Concurrent::ErlangActor::Down
- ::new — Concurrent::ErlangActor::NoActor
- ::new — Concurrent::Edge::LockFreeLinkedSet
- ::new — Concurrent::Edge::LockFreeLinkedSet::Node
- ::new — Concurrent::Edge::LockFreeLinkedSet::Tail
- ::new — Concurrent::Edge::LockFreeLinkedSet::Window
- ::new — Concurrent::LockFreeQueue
- ::new — Concurrent::LockFreeQueue::Node
- ::new — Concurrent::ProcessingActor
- ::new — Concurrent::Throttle
- ::new — Concurrent::Throttle::ProxyExecutor
- ::new — Concurrent::WrappingExecutor
- ::new — Concurrent::LazyRegister
- ::new — Concurrent::Actor::Utils::AsAdHoc
- ::new — Concurrent::ErlangActor::HasFrom
- ::new — Concurrent::ErlangActor::HasReason
- ::new — Concurrent::ErlangActor::HasReference
- ::restarting_behaviour_definition — Concurrent::Actor::Behaviour
- ::root — Concurrent::Actor
- ::select — Concurrent::Channel
- ::select — Concurrent::Promises::Channel
- ::select_matching — Concurrent::Promises::Channel
- ::select_op — Concurrent::Promises::Channel
- ::select_op_matching — Concurrent::Promises::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
- ::timeout — Concurrent::Cancellation
- ::timer — Concurrent::Channel
- ::to_spawn_options — Concurrent::Actor::AbstractContext
- ::to_spawn_options — Concurrent::Actor
- ::try_select — Concurrent::Promises::Channel
- ::try_select_matching — Concurrent::Promises::Channel
- ::user_messages — Concurrent::Actor::Behaviour
- #<< — Concurrent::Actor::AbstractContext
- #<< — Concurrent::Actor::Reference
- #<< — Concurrent::Channel
- #<< — Concurrent::Edge::LockFreeLinkedSet
- #<=> — Concurrent::Channel::Tick
- #<=> — Concurrent::Promises::Channel
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Node
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Tail
- #<=> — Concurrent::Edge::LockFreeLinkedSet::Head
- #== — Concurrent::Actor::Reference
- #== — Concurrent::ErlangActor::Terminated
- #== — Concurrent::ErlangActor::DownSignal
- #== — Concurrent::ErlangActor::Down
- #== — Concurrent::ErlangActor::NoActor
- #== — Concurrent::ErlangActor::HasFrom
- #== — Concurrent::ErlangActor::HasReason
- #== — Concurrent::ErlangActor::HasReference
- #=== — Concurrent::ErlangActor::EnvironmentConstants::And
- #=== — Concurrent::ErlangActor::EnvironmentConstants::Or
- #[] — Concurrent::LazyRegister
- #~ — Concurrent::Channel
- #Child! — Concurrent::Actor::TypeCheck
- #Child? — Concurrent::Actor::TypeCheck
- #Match! — Concurrent::Actor::TypeCheck
- #Match? — Concurrent::Actor::TypeCheck
- #Type! — Concurrent::Actor::TypeCheck
- #Type? — Concurrent::Actor::TypeCheck
- #acquire — Concurrent::Throttle
- #acquire_or_event — Concurrent::Throttle
- #actor_class — Concurrent::Actor::PublicDelegations
- #add — Concurrent::Edge::LockFreeLinkedSet
- #add — Concurrent::LazyRegister
- #add_child — Concurrent::Actor::Core
- #address_path — Concurrent::Actor::Envelope
- #after — Concurrent::Channel::Selector
- #after_termination — Concurrent::ErlangActor::AbstractActor
- #allocate_context — Concurrent::Actor::Core
- #apply_behaviour — Concurrent::ErlangActor::OnPool
- #ask — Concurrent::Actor::AbstractContext
- #ask — Concurrent::Actor::Reference
- #ask — Concurrent::ErlangActor::Pid
- #ask — Concurrent::ErlangActor::AbstractActor
- #ask! — Concurrent::Actor::AbstractContext
- #ask! — Concurrent::Actor::Reference
- #ask_op — Concurrent::Actor::Reference
- #ask_op — Concurrent::ErlangActor::Pid
- #ask_op — Concurrent::ErlangActor::AbstractActor
- #ask_op — Concurrent::ProcessingActor
- #asked? — Concurrent::ErlangActor::AbstractActor
- #available_capacity — Concurrent::Throttle
- #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
- #blocking? — Concurrent::Channel::Buffer::Base
- #blocking? — Concurrent::Channel::Buffer::Dropping
- #blocking? — Concurrent::Channel::Buffer::Sliding
- #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
- #can_overflow? — Concurrent::Throttle::ProxyExecutor
- #can_overflow? — Concurrent::WrappingExecutor
- #canceled? — Concurrent::Cancellation
- #canonical_rules — Concurrent::ErlangActor::AbstractActor
- #capacity — Concurrent::Promises::Channel
- #capacity= — Concurrent::Channel::Buffer::Base
- #case — Concurrent::Channel::Selector
- #check! — Concurrent::Cancellation
- #children — Concurrent::Actor::Core
- #children — Concurrent::Actor::InternalDelegations
- #clean_reply — Concurrent::ErlangActor::AbstractActor
- #close — Concurrent::Channel::Buffer::Base
- #closed= — Concurrent::Channel::Buffer::Base
- #closed? — Concurrent::Channel::Buffer::Base
- #consume_exit — Concurrent::ErlangActor::AbstractActor
- #consume_signal — Concurrent::ErlangActor::AbstractActor
- #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_actor_executor — Concurrent::ErlangActor::Functions
- #default_executor — Concurrent::Actor::AbstractContext
- #default_executor — Concurrent::ErlangActor::Environment
- #default_executor — Concurrent::Throttle
- #default_executor — Concurrent::ErlangActor::Functions
- #default_reference_class — Concurrent::Actor::AbstractContext
- #delete — Concurrent::LazyRegister
- #demonitor — Concurrent::ErlangActor::Environment
- #demonitor — Concurrent::ErlangActor::AbstractActor
- #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
- #empty? — Concurrent::Channel::Buffer::Base
- #empty? — Concurrent::Channel::Buffer::Unbuffered
- #envelope — Concurrent::Actor::AbstractContext
- #epoch — Concurrent::Channel::Tick
- #eql? — Concurrent::ErlangActor::Terminated
- #eql? — Concurrent::ErlangActor::Down
- #eql? — Concurrent::ErlangActor::NoActor
- #eql? — Concurrent::ErlangActor::HasFrom
- #error — Concurrent::Channel::Selector
- #eval_task — Concurrent::ErlangActor::AbstractActor
- #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::Actor::PublicDelegations
- #filtered_receivers — Concurrent::Actor::Utils::Broadcast
- #full? — Concurrent::Channel::Buffer::Base
- #full? — Concurrent::Channel::Buffer::Unbuffered
- #guard! — Concurrent::Actor::Core
- #has_key? — Concurrent::LazyRegister
- #hash — Concurrent::ErlangActor::Terminated
- #hash — Concurrent::ErlangActor::DownSignal
- #hash — Concurrent::ErlangActor::Down
- #hash — Concurrent::ErlangActor::NoActor
- #hash — Concurrent::ErlangActor::HasFrom
- #hash — Concurrent::ErlangActor::HasReason
- #hash — Concurrent::ErlangActor::HasReference
- #initial_signal_consumption — Concurrent::ErlangActor::AbstractActor
- #initialize_behaviours — Concurrent::Actor::Core
- #initialize_core — Concurrent::Actor::AbstractContext
- #inner_post — Concurrent::Throttle::ProxyExecutor
- #inner_run — Concurrent::ErlangActor::OnPool
- #inspect — Concurrent::Actor::Reference
- #inspect — Concurrent::Cancellation
- #inspect — Concurrent::Promises::Channel
- #inspect — Concurrent::ErlangActor::Pid
- #inspect — Concurrent::ErlangActor::Token
- #inspect — Concurrent::ProcessingActor
- #inspect — Concurrent::Throttle
- #internal_receive — Concurrent::ErlangActor::OnPool
- #item — Concurrent::LockFreeQueue::Node
- #join — Concurrent::Cancellation
- #key — Concurrent::Edge::LockFreeLinkedSet::Node
- #key? — Concurrent::LazyRegister
- #key_for — Concurrent::Edge::LockFreeLinkedSet::Node
- #last? — Concurrent::Edge::LockFreeLinkedSet::Node
- #link — Concurrent::Actor::Behaviour::Linking
- #link — Concurrent::ErlangActor::Environment
- #link — Concurrent::ErlangActor::AbstractActor
- #linked? — Concurrent::ErlangActor::Environment
- #linked? — Concurrent::ErlangActor::AbstractActor
- #log — Concurrent::Actor::Core
- #log — Concurrent::Actor::InternalDelegations
- #mailbox — Concurrent::ProcessingActor
- #map — Concurrent::Actor::Reference
- #max_capacity — Concurrent::Throttle
- #message — Concurrent::Actor::Reference
- #monitor — Concurrent::ErlangActor::Environment
- #monitor — Concurrent::ErlangActor::AbstractActor
- #monitoring? — Concurrent::ErlangActor::Environment
- #monitoring? — Concurrent::ErlangActor::AbstractActor
- #monotonic_to_utc — Concurrent::Channel::Tick
- #name — Concurrent::ErlangActor::Pid
- #name — Concurrent::ErlangActor::Environment
- #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
- #ns_closed? — Concurrent::Channel::Buffer::Base
- #ns_consume_pending_push — Concurrent::Promises::Channel
- #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_pop_op — Concurrent::Promises::Channel
- #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_shift_message — Concurrent::Promises::Channel
- #ns_size — Concurrent::Channel::Buffer::Base
- #ns_size — Concurrent::Channel::Buffer::Buffered
- #ns_size — Concurrent::Channel::Buffer::Timer
- #ns_try_push — Concurrent::Promises::Channel
- #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 — Concurrent::ErlangActor::Environment
- #on — Concurrent::ErlangActor::AbstractActor
- #on — Concurrent::Throttle
- #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_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
- #origin — Concurrent::Cancellation
- #parent — Concurrent::Actor::Core
- #parent — Concurrent::Actor::PublicDelegations
- #partial_select_op — Concurrent::Promises::Channel
- #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::Promises::Channel
- #peek_matching — Concurrent::Promises::Channel
- #pid — Concurrent::ErlangActor::Environment
- #pid — Concurrent::ErlangActor::AbstractActor
- #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::Promises::Channel
- #pop — Concurrent::LockFreeQueue
- #pop_matching — Concurrent::Promises::Channel
- #pop_op — Concurrent::Promises::Channel
- #pop_op_matching — Concurrent::Promises::Channel
- #post — Concurrent::Throttle::ProxyExecutor
- #post — Concurrent::WrappingExecutor
- #process_envelope — Concurrent::Actor::Behaviour::Buffer
- #process_envelope — Concurrent::Actor::Core
- #process_envelopes? — Concurrent::Actor::Behaviour::Buffer
- #push — Concurrent::Promises::Channel
- #push — Concurrent::LockFreeQueue
- #push_op — Concurrent::Promises::Channel
- #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
- #rebuild_context — Concurrent::Actor::Behaviour::Pausing
- #receive — Concurrent::Channel
- #receive — Concurrent::Channel::Selector
- #receive — Concurrent::ErlangActor::Environment
- #receive — Concurrent::ErlangActor::AbstractActor
- #receive — Concurrent::ErlangActor::OnPool
- #receive — Concurrent::ErlangActor::OnThread
- #receive — Concurrent::ProcessingActor
- #redirect — Concurrent::Actor::InternalDelegations
- #ref — Concurrent::Actor::PublicDelegations
- #reference — Concurrent::Actor::PublicDelegations
- #register — Concurrent::LazyRegister
- #registered? — Concurrent::LazyRegister
- #reject! — Concurrent::Actor::Envelope
- #reject_deferred — Concurrent::Actor::Behaviour::Pausing
- #reject_envelope — Concurrent::Actor::Behaviour::Abstract
- #release — Concurrent::Throttle
- #release — Concurrent::Promises::Resolvable
- #remove — Concurrent::Edge::LockFreeLinkedSet
- #remove — Concurrent::LazyRegister
- #remove_child — Concurrent::Actor::Core
- #reply — Concurrent::ErlangActor::Environment
- #reply_resolution — Concurrent::ErlangActor::Environment
- #reply_resolution — Concurrent::ErlangActor::AbstractActor
- #reschedule_deferred — Concurrent::Actor::Behaviour::Pausing
- #reserve — Concurrent::Promises::Resolvable
- #reset! — Concurrent::Actor::Behaviour::Pausing
- #restart! — Concurrent::Actor::Behaviour::Pausing
- #resume! — Concurrent::Actor::Behaviour::Pausing
- #run — Concurrent::ErlangActor::OnPool
- #run — Concurrent::ErlangActor::OnThread
- #schedule_execution — Concurrent::Actor::Core
- #select — Concurrent::Promises::Channel
- #select — Concurrent::Promises::FactoryMethods::OldChannelIntegration
- #select_matching — Concurrent::Promises::Channel
- #select_op — Concurrent::Promises::Channel
- #select_op_matching — Concurrent::Promises::Channel
- #send — Concurrent::Channel
- #send — Concurrent::Channel::Selector
- #send_exit_messages — Concurrent::ErlangActor::AbstractActor
- #sender_path — Concurrent::Actor::Envelope
- #serialized? — Concurrent::Throttle::ProxyExecutor
- #serialized? — Concurrent::WrappingExecutor
- #size — Concurrent::Channel::Buffer::Base
- #size — Concurrent::Channel::Buffer::Unbuffered
- #size — Concurrent::Promises::Channel
- #size — Concurrent::LockFreeQueue
- #size= — Concurrent::Channel::Buffer::Base
- #spawn — Concurrent::ErlangActor::Environment
- #spawn — Concurrent::ErlangActor::AbstractActor
- #spawn — Concurrent::ErlangActor::FunctionShortcuts
- #spawn_actor — Concurrent::ErlangActor::Functions
- #store — Concurrent::LazyRegister
- #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
- #tell — Concurrent::Actor::AbstractContext
- #tell — Concurrent::Actor::Reference
- #tell — Concurrent::ErlangActor::Pid
- #tell — Concurrent::ErlangActor::AbstractActor
- #tell! — Concurrent::ProcessingActor
- #tell_op — Concurrent::ErlangActor::Pid
- #tell_op — Concurrent::ErlangActor::AbstractActor
- #tell_op — Concurrent::ProcessingActor
- #terminate — Concurrent::ErlangActor::Environment
- #terminate — Concurrent::ErlangActor::AbstractActor
- #terminate — Concurrent::ErlangActor::FunctionShortcuts
- #terminate! — Concurrent::Actor::Behaviour::Termination
- #terminate! — Concurrent::Actor::InternalDelegations
- #terminate_actor — Concurrent::ErlangActor::Functions
- #terminate_self — Concurrent::ErlangActor::AbstractActor
- #terminate_self — Concurrent::ErlangActor::OnPool
- #terminate_self — Concurrent::ErlangActor::OnThread
- #terminated — Concurrent::ErlangActor::Pid
- #terminated — Concurrent::ErlangActor::Environment
- #terminated — Concurrent::ErlangActor::AbstractActor
- #terminated? — Concurrent::Actor::Behaviour::Termination
- #terminated? — Concurrent::Actor::InternalDelegations
- #termination — Concurrent::ProcessingActor
- #then_ask — Concurrent::Promises::Future::ActorIntegration
- #then_channel_push — Concurrent::Promises::Future::NewChannelIntegration
- #then_flat — Concurrent::Promises::Future::FlatShortcuts
- #then_flat_event — Concurrent::Promises::Future::FlatShortcuts
- #then_flat_event_on — Concurrent::Promises::Future::FlatShortcuts
- #then_flat_future — Concurrent::Promises::Future::FlatShortcuts
- #then_flat_future_on — Concurrent::Promises::Future::FlatShortcuts
- #then_flat_on — Concurrent::Promises::Future::FlatShortcuts
- #then_put — Concurrent::Promises::Future::OldChannelIntegration
- #then_select — Concurrent::Promises::Future::OldChannelIntegration
- #timeout — Concurrent::Channel::Selector
- #to_ary — Concurrent::Cancellation
- #to_ary — Concurrent::ErlangActor::Terminated
- #to_ary — Concurrent::ErlangActor::DownSignal
- #to_ary — Concurrent::ErlangActor::Down
- #to_ary — Concurrent::ProcessingActor
- #to_ary — Concurrent::ErlangActor::HasReason
- #to_ary — Concurrent::ErlangActor::HasReference
- #to_s — Concurrent::Actor::Reference
- #to_s — Concurrent::Channel::Tick
- #to_s — Concurrent::Cancellation
- #to_s — Concurrent::Promises::Channel
- #to_s — Concurrent::ErlangActor::Pid
- #to_s — Concurrent::ErlangActor::Token
- #to_s — Concurrent::ProcessingActor
- #to_s — Concurrent::Throttle
- #trap — Concurrent::ErlangActor::Environment
- #trap — Concurrent::ErlangActor::AbstractActor
- #trapping= — Concurrent::Actor::Behaviour::Termination
- #trapping? — Concurrent::Actor::Behaviour::Termination
- #traps? — Concurrent::ErlangActor::Environment
- #traps? — Concurrent::ErlangActor::AbstractActor
- #try_acquire — Concurrent::Throttle
- #try_pop — Concurrent::Promises::Channel
- #try_pop_matching — Concurrent::Promises::Channel
- #try_push — Concurrent::Promises::Channel
- #try_select — Concurrent::Promises::Channel
- #try_select_matching — Concurrent::Promises::Channel
- #unlink — Concurrent::Actor::Behaviour::Linking
- #unlink — Concurrent::ErlangActor::Environment
- #unlink — Concurrent::ErlangActor::AbstractActor
- #unregister — Concurrent::LazyRegister
- #validate — Concurrent::Channel
- #validator — Concurrent::Channel
- #validator= — Concurrent::Channel
- #zip_futures_over — Concurrent::Promises::FactoryMethods
- #zip_futures_over_on — Concurrent::Promises::FactoryMethods