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