Module: Concurrent::Actor::InternalDelegations

Includes:

PublicDelegations, Logger::Severity

Included in:

AbstractContext, Behaviour::Abstract

Defined in:

lib/concurrent/actor/internal_delegations.rb

Instance Method Summary (collapse)

• - (undocumented) behaviour(behaviour_class)

  see Core#behaviour.

• - (undocumented) behaviour!(behaviour_class)

  see Core#behaviour!.

• - (undocumented) children
• - (AbstractContext) context
• - (undocumented) context_class (also: #actor_class) included from PublicDelegations
• - (undocumented) dead_letter_routing
• - (undocumented) executor included from PublicDelegations
• - (undocumented) log(level, message = nil, &block)

  delegates to core.log.

• - (undocumented) name included from PublicDelegations
• - (undocumented) parent included from PublicDelegations
• - (undocumented) path included from PublicDelegations
• - (undocumented) redirect(reference, envelope = self.envelope)
• - (undocumented) reference (also: #ref) included from PublicDelegations
• - (undocumented) terminate!(reason = nil)
• - (Boolean) terminated?

49
50
51

# File 'lib/concurrent/actor/internal_delegations.rb', line 49

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

54
55
56

# File 'lib/concurrent/actor/internal_delegations.rb', line 54

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

8
9
10

# File 'lib/concurrent/actor/internal_delegations.rb', line 8

def children
  core.children
end

44
45
46

# File 'lib/concurrent/actor/internal_delegations.rb', line 44

def context
  core.context
end

34
35
36

# File 'lib/concurrent/actor/internal_delegations.rb', line 34

def dead_letter_routing
  context.dead_letter_routing
end

29
30
31

# File 'lib/concurrent/actor/internal_delegations.rb', line 29

def log(level, message = nil, &block)
  core.log(level, message, &block)
end

38
39
40
41

# File 'lib/concurrent/actor/internal_delegations.rb', line 38

def redirect(reference, envelope = self.envelope)
  reference.message(envelope.message, envelope.future)
  Behaviour::MESSAGE_PROCESSED
end

13
14
15

# File 'lib/concurrent/actor/internal_delegations.rb', line 13

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

18
19
20

# File 'lib/concurrent/actor/internal_delegations.rb', line 18

def terminated?
  behaviour!(Behaviour::Termination).terminated?
end