123456789_123456789_123456789_123456789_123456789_

Module: Concurrent::Actor::InternalDelegations

Constant Summary

Concern::Logging - Included

SEV_LABEL

Instance Attribute Summary

Instance Method Summary

Instance Attribute Details

#terminated?Boolean (readonly)

See Also:

  • Termination#terminated?
[ GitHub ]

  
# 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)

[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 52

def behaviour(behaviour_class)
  core.behaviour(behaviour_class)
end

#behaviour!(behaviour_class)

[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 57

def behaviour!(behaviour_class)
  core.behaviour!(behaviour_class)
end

#children

See Also:

[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 11

def children
  core.children
end

#contextAbstractContext

[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 47

def context
  core.context
end

#dead_letter_routing

[ GitHub ]

  
# 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

See Also:

  • Logging#log
[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 32

def log(level, message = nil, &block)
  core.log(level, message, &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.message(envelope.message, envelope.future)
  Behaviour::MESSAGE_PROCESSED
end

#terminate!(reason = nil)

See Also:

  • Termination#terminate!
[ GitHub ]

  
# File 'lib/concurrent-ruby-edge/concurrent/actor/internal_delegations.rb', line 16

def terminate!(reason = nil)
  behaviour!(Behaviour::Termination).terminate!(reason)
end