Module: Concurrent::Actor::InternalDelegations
- Includes:
- PublicDelegations, Logger::Severity
- Included in:
- AbstractContext, Behaviour::Abstract
- Defined in:
- lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb
Instance Method Summary collapse
-
#behaviour(behaviour_class) ⇒ undocumented
see Core#behaviour.
-
#behaviour!(behaviour_class) ⇒ undocumented
see Core#behaviour!.
- #children ⇒ undocumented
- #context ⇒ AbstractContext
- #dead_letter_routing ⇒ undocumented
-
#log(level, message = nil, &block) ⇒ undocumented
delegates to core.log.
- #redirect(reference, envelope = self.envelope) ⇒ undocumented
- #terminate!(reason = nil) ⇒ undocumented
- #terminated? ⇒ Boolean
- #context_class ⇒ undocumented (also: #actor_class) included from PublicDelegations
- #executor ⇒ undocumented included from PublicDelegations
- #name ⇒ undocumented included from PublicDelegations
- #parent ⇒ undocumented included from PublicDelegations
- #path ⇒ undocumented included from PublicDelegations
- #reference ⇒ undocumented (also: #ref) included from PublicDelegations
Instance Method Details
#behaviour(behaviour_class) ⇒ undocumented
see Core#behaviour
49 50 51 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 49 def behaviour(behaviour_class) core.behaviour(behaviour_class) end |
#behaviour!(behaviour_class) ⇒ undocumented
see Core#behaviour!
54 55 56 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 54 def behaviour!(behaviour_class) core.behaviour!(behaviour_class) end |
#children ⇒ undocumented
8 9 10 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 8 def children core.children end |
#context ⇒ AbstractContext
44 45 46 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 44 def context core.context end |
#dead_letter_routing ⇒ undocumented
34 35 36 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 34 def dead_letter_routing context.dead_letter_routing end |
#log(level, message = nil, &block) ⇒ undocumented
delegates to core.log
29 30 31 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 29 def log(level, = nil, &block) core.log(level, , &block) end |
#redirect(reference, envelope = self.envelope) ⇒ undocumented
38 39 40 41 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 38 def redirect(reference, envelope = self.envelope) reference.(envelope., envelope.future) Behaviour::MESSAGE_PROCESSED end |
#terminate!(reason = nil) ⇒ undocumented
13 14 15 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 13 def terminate!(reason = nil) behaviour!(Behaviour::Termination).terminate!(reason) end |
#terminated? ⇒ Boolean
18 19 20 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 18 def terminated? behaviour!(Behaviour::Termination).terminated? end |