Module: Concurrent::Actor::InternalDelegations
- Includes:
- PublicDelegations
- 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
52 53 54 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 52 def behaviour(behaviour_class) core.behaviour(behaviour_class) end |
#behaviour!(behaviour_class) ⇒ undocumented
see Core#behaviour!
57 58 59 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 57 def behaviour!(behaviour_class) core.behaviour!(behaviour_class) end |
#children ⇒ undocumented
11 12 13 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 11 def children core.children end |
#context ⇒ AbstractContext
47 48 49 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 47 def context core.context end |
#dead_letter_routing ⇒ undocumented
37 38 39 |
# 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) ⇒ undocumented
delegates to core.log
32 33 34 |
# 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) ⇒ undocumented
41 42 43 44 |
# 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) ⇒ undocumented
16 17 18 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 16 def terminate!(reason = nil) behaviour!(Behaviour::Termination).terminate!(reason) end |
#terminated? ⇒ Boolean
21 22 23 |
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 21 def terminated? behaviour!(Behaviour::Termination).terminated? end |