Module: Concurrent::Actor::InternalDelegations
Relationships & Source Files | |
Extension / Inclusion / Inheritance Descendants | |
Included In:
AbstractContext ,
Behaviour::Abstract ,
Behaviour::Awaits ,
Behaviour::Buffer ,
Behaviour::ErrorsOnUnknownMessage ,
Behaviour::ExecutesContext ,
Behaviour::Linking ,
Behaviour::Pausing ,
Behaviour::RemovesChild ,
Behaviour::SetResults ,
Behaviour::Supervising ,
Behaviour::Termination ,
Context ,
DefaultDeadLetterHandler ,
RestartingContext ,
Root ,
Utils::AdHoc ,
Utils::Balancer ,
Utils::Broadcast ,
Utils::Pool
| |
Super Chains via Extension / Inclusion / Inheritance | |
Instance Chain:
|
|
Defined in: | lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb |
Constant Summary
Concern::Logging
- Included
Instance Attribute Summary
- #terminated? ⇒ Boolean readonly
Instance Method Summary
-
#behaviour(behaviour_class)
see Core#behaviour
-
#behaviour!(behaviour_class)
see Core#behaviour!
- #children
- #context ⇒ AbstractContext
- #dead_letter_routing
-
#log(level, message = nil, &block)
delegates to core.log.
- #redirect(reference, envelope = self.envelope)
- #terminate!(reason = nil)
Concern::Logging
- Included
#log | Logs through Concurrent.global_logger, it can be overridden by setting @logger. |
PublicDelegations
- Included
#actor_class | Alias for PublicDelegations#context_class. |
#context_class, #executor, #name, #parent, #path, | |
#ref | Alias for PublicDelegations#reference. |
#reference |
Instance Attribute Details
#terminated? ⇒ Boolean
(readonly)
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 21
def terminated? behaviour!(Behaviour::Termination).terminated? end
Instance Method Details
#behaviour(behaviour_class)
see Core#behaviour
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 52
def behaviour(behaviour_class) core.behaviour(behaviour_class) end
#behaviour!(behaviour_class)
see Core#behaviour!
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 57
def behaviour!(behaviour_class) core.behaviour!(behaviour_class) end
#children
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 11
def children core.children end
#context ⇒ AbstractContext
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 47
def context core.context end
#dead_letter_routing
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 37
def dead_letter_routing context.dead_letter_routing end
#log(level, message = nil, &block)
delegates to core.log
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 32
def log(level, = nil, &block) core.log(level, , &block) end
#redirect(reference, envelope = self.envelope)
[ GitHub ]# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 41
def redirect(reference, envelope = self.envelope) reference. (envelope., envelope.future) Behaviour::MESSAGE_PROCESSED end
#terminate!(reason = nil)
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 16
def terminate!(reason = nil) behaviour!(Behaviour::Termination).terminate!(reason) end