Table of Contents - concurrent-ruby-edge-0.4.1 Documentation
Pages
-
CHANGELOG
- Current
- 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
- 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::Cancellation::Token
- 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::LazyRegister
- Concurrent::LockFreeQueue
- Concurrent::LockFreeQueue::Node
- Concurrent::ProcessingActor
- Concurrent::Promises
- Concurrent::Promises::AbstractEventFuture
- Concurrent::Promises::AbstractEventFuture::ThrottleIntegration
- Concurrent::Promises::Channel
- Concurrent::Promises::FactoryMethods
- Concurrent::Promises::FactoryMethods::NewChannelIntegration
- 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::Future::ThrottleIntegration
- Concurrent::Throttle
- Concurrent::Throttle::PromisesIntegration
Methods
- ::act — Concurrent::ProcessingActor
- ::act_listening — Concurrent::ProcessingActor
- ::after — Concurrent::Channel
- ::alt — Concurrent::Channel
- ::base — Concurrent::Actor::Behaviour
- ::basic_behaviour_definition — Concurrent::Actor::Behaviour
- ::create — Concurrent::Cancellation
- ::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::Cancellation
- ::new — Concurrent::Cancellation::Token
- ::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::Promises::Channel
- ::new — Concurrent::Throttle
- ::new — Concurrent::LazyRegister
- ::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::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::Promises::Channel
- #== — 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
- #[] — Concurrent::LazyRegister
- #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
- #allocate_context — Concurrent::Actor::Core
- #ask — Concurrent::Actor::AbstractContext
- #ask — Concurrent::Actor::Reference
- #ask — Concurrent::ProcessingActor
- #ask! — Concurrent::Actor::AbstractContext
- #ask! — Concurrent::Actor::Reference
- #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
- #cancel — Concurrent::Cancellation
- #canceled? — Concurrent::Cancellation
- #canceled? — Concurrent::Cancellation::Token
- #capacity= — Concurrent::Channel::Buffer::Base
- #case — Concurrent::Channel::Selector
- #chain_throttled_by — Concurrent::Promises::AbstractEventFuture::ThrottleIntegration
- #children — Concurrent::Actor::Core
- #children — Concurrent::Actor::InternalDelegations
- #close — Concurrent::Channel::Buffer::Base
- #closed= — Concurrent::Channel::Buffer::Base
- #closed? — Concurrent::Channel::Buffer::Base
- #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_reference_class — Concurrent::Actor::AbstractContext
- #delete — Concurrent::LazyRegister
- #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
- #error — Concurrent::Channel::Selector
- #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
- #initialize_behaviours — Concurrent::Actor::Core
- #initialize_core — Concurrent::Actor::AbstractContext
- #inspect — Concurrent::Actor::Reference
- #inspect — Concurrent::Cancellation
- #inspect — Concurrent::Cancellation::Token
- #inspect — Concurrent::ProcessingActor
- #inspect — Concurrent::Promises::Channel
- #inspect — Concurrent::Throttle
- #item — Concurrent::LockFreeQueue::Node
- #join — Concurrent::Cancellation::Token
- #key — Concurrent::Edge::LockFreeLinkedSet::Node
- #key? — Concurrent::LazyRegister
- #key_for — Concurrent::Edge::LockFreeLinkedSet::Node
- #last? — Concurrent::Edge::LockFreeLinkedSet::Node
- #limit — Concurrent::Throttle
- #link — Concurrent::Actor::Behaviour::Linking
- #log — Concurrent::Actor::Core
- #log — Concurrent::Actor::InternalDelegations
- #loop_until_canceled — Concurrent::Cancellation::Token
- #mailbox — Concurrent::ProcessingActor
- #map — Concurrent::Actor::Reference
- #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
- #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_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
- #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
- #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::LockFreeQueue
- #pop — Concurrent::Promises::Channel
- #pop_for_select — Concurrent::Promises::Channel
- #process_envelope — Concurrent::Actor::Behaviour::Buffer
- #process_envelope — Concurrent::Actor::Core
- #process_envelopes? — Concurrent::Actor::Behaviour::Buffer
- #push — Concurrent::LockFreeQueue
- #push — 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
- #raise_if_canceled — Concurrent::Cancellation::Token
- #rebuild_context — Concurrent::Actor::Behaviour::Pausing
- #receive — Concurrent::Channel
- #receive — Concurrent::Channel::Selector
- #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
- #remove — Concurrent::Edge::LockFreeLinkedSet
- #remove — Concurrent::LazyRegister
- #remove_child — Concurrent::Actor::Core
- #reschedule_deferred — Concurrent::Actor::Behaviour::Pausing
- #rescue_throttled_by — Concurrent::Promises::Future::ThrottleIntegration
- #reset! — Concurrent::Actor::Behaviour::Pausing
- #restart! — Concurrent::Actor::Behaviour::Pausing
- #resume! — Concurrent::Actor::Behaviour::Pausing
- #schedule_execution — Concurrent::Actor::Core
- #select — Concurrent::Promises::FactoryMethods::OldChannelIntegration
- #select_channel — Concurrent::Promises::FactoryMethods::NewChannelIntegration
- #send — Concurrent::Channel
- #send — Concurrent::Channel::Selector
- #sender_path — Concurrent::Actor::Envelope
- #size — Concurrent::Channel::Buffer::Base
- #size — Concurrent::Channel::Buffer::Unbuffered
- #size — Concurrent::LockFreeQueue
- #size= — Concurrent::Channel::Buffer::Base
- #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::ProcessingActor
- #tell! — Concurrent::ProcessingActor
- #terminate! — Concurrent::Actor::Behaviour::Termination
- #terminate! — Concurrent::Actor::InternalDelegations
- #terminated? — Concurrent::Actor::Behaviour::Termination
- #terminated? — Concurrent::Actor::InternalDelegations
- #termination — Concurrent::ProcessingActor
- #then_ask — Concurrent::Promises::Future::ActorIntegration
- #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_push_channel — Concurrent::Promises::Future::NewChannelIntegration
- #then_put — Concurrent::Promises::Future::OldChannelIntegration
- #then_select — Concurrent::Promises::Future::OldChannelIntegration
- #then_throttled_by — Concurrent::Promises::Future::ThrottleIntegration
- #throttled_block — Concurrent::Throttle
- #throttled_by — Concurrent::Promises::AbstractEventFuture::ThrottleIntegration
- #throttled_future — Concurrent::Throttle::PromisesIntegration
- #throttled_future_chain — Concurrent::Throttle::PromisesIntegration
- #timeout — Concurrent::Channel::Selector
- #to_event — Concurrent::Cancellation::Token
- #to_future — Concurrent::Cancellation::Token
- #to_s — Concurrent::Actor::Reference
- #to_s — Concurrent::Channel::Tick
- #to_s — Concurrent::Cancellation
- #to_s — Concurrent::Cancellation::Token
- #to_s — Concurrent::Promises::Channel
- #to_s — Concurrent::Throttle
- #token — Concurrent::Cancellation
- #trapping= — Concurrent::Actor::Behaviour::Termination
- #trapping? — Concurrent::Actor::Behaviour::Termination
- #trigger — Concurrent::Throttle
- #unlink — Concurrent::Actor::Behaviour::Linking
- #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
- #~ — Concurrent::Channel