Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://ruby-concurrency.github.io/concurrent-ruby/master/Concurrent/Actor/AbstractContext.html below:

Class: Concurrent::Actor::AbstractContext — Concurrent Ruby

New actor is defined by subclassing RestartingContext, Context and defining its abstract methods. AbstractContext can be subclassed directly to implement more specific behaviour see Root implementation.

• Context

  Basic Context of an Actor. It supports only linking and it simply terminates on error. Uses Behaviour.basic_behaviour_definition:

• RestartingContext.

  Context of an Actor for robust systems. It supports supervision, linking, pauses on error. Uses Behaviour.restarting_behaviour_definition

Example of ac actor definition:

Message = Struct.new :action, :value 

class AnActor < Concurrent::Actor::RestartingContext
  def initialize(init)
    @counter = init
  end

    def on_message(message)
    case message.action
    when :add
      @counter = @counter + message.value
    when :subtract
      @counter = @counter - message.value
    when :value
      @counter
    else
      pass
    end
  end

    def on_event(event)
    if event == :reset
      @counter = 0     end
  end
end 

an_actor = AnActor.spawn name: 'an_actor', args: 10 
an_actor << Message.new(:add, 1) << Message.new(:subtract, 2) 
an_actor.ask!(Message.new(:value, nil))            an_actor << :boo << Message.new(:add, 1) 
an_actor.ask!(Message.new(:value, nil))            an_actor << :terminate!
    

See methods of AbstractContext what else can be tweaked, e.g #default_reference_class

• #core ⇒ undocumented readonly

• .spawn(name_or_opts, *args, &block) ⇒ undocumented

  Behaves as spawn but :class is auto-inserted based on receiver so it can be omitted.

• .spawn!(name_or_opts, *args, &block) ⇒ undocumented

  behaves as spawn! but :class is auto-inserted based on receiver so it can be omitted.

• #ask(message) ⇒ undocumented (also: #ask!)
• #behaviour_definition ⇒ Array<Array(Behavior::Abstract, Array<Object>)>
• #dead_letter_routing ⇒ Reference

  Defines an actor responsible for dead letters.

• #default_executor ⇒ Executor

  override to se different default executor, e.g.

• #default_reference_class ⇒ CLass

  override if different class for reference is needed.

• #envelope ⇒ Envelope

  Current envelope, accessible inside #on_message processing.

• #on_envelope(envelope) ⇒ undocumented private
• #on_event(event) ⇒ undocumented

  override to add custom code invocation on internal events like :terminated, :resumed, anError.

• #on_message(message) ⇒ Object abstract

  A result which will be used to set the Future supplied to Reference#ask.

• #pass ⇒ undocumented

  if you want to pass the message to next behaviour, usually Behaviour::ErrorsOnUnknownMessage.

• #tell(message) ⇒ undocumented (also: #<<)

  tell self a message.

• #behaviour(behaviour_class) ⇒ undocumented included from InternalDelegations

  see Core#behaviour.

• #behaviour!(behaviour_class) ⇒ undocumented included from InternalDelegations

  see Core#behaviour!.

• #Child!(value, *types) ⇒ undocumented included from TypeCheck
• #Child?(value, *types) ⇒ Boolean included from TypeCheck
• #children ⇒ undocumented included from InternalDelegations
• #context ⇒ AbstractContext included from InternalDelegations
• #context_class ⇒ undocumented (also: #actor_class) included from PublicDelegations
• #executor ⇒ undocumented included from PublicDelegations
• #log(level, message = nil, &block) ⇒ undocumented included from InternalDelegations

  delegates to core.log.

• #Match!(value, *types) ⇒ undocumented included from TypeCheck
• #Match?(value, *types) ⇒ Boolean included from TypeCheck
• #name ⇒ undocumented included from PublicDelegations
• #parent ⇒ undocumented included from PublicDelegations
• #path ⇒ undocumented included from PublicDelegations
• #redirect(reference, envelope = self.envelope) ⇒ undocumented included from InternalDelegations
• #reference ⇒ undocumented (also: #ref) included from PublicDelegations
• #terminate!(reason = nil) ⇒ undocumented included from InternalDelegations
• #terminated? ⇒ Boolean included from InternalDelegations
• #Type!(value, *types) ⇒ undocumented included from TypeCheck
• #Type?(value, *types) ⇒ Boolean included from TypeCheck

30
31
32

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 30

def core
  @core
end

117
118
119

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 117

def self.spawn(name_or_opts, *args, &block)
  Actor.spawn to_spawn_options(name_or_opts, *args), &block
end

122
123
124

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 122

def self.spawn!(name_or_opts, *args, &block)
  Actor.spawn! to_spawn_options(name_or_opts, *args), &block
end

98
99
100

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 98

def ask(message)
  raise 'actor cannot ask itself'
end

72
73
74

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 72

def behaviour_definition
  raise NotImplementedError
end

Defines an actor responsible for dead letters. Any rejected message send with Reference#tell is sent there, a message with future is considered already monitored for failures. Default behaviour is to use #dead_letter_routing of the parent, so if no #dead_letter_routing method is overridden in parent-chain the message ends up in Actor.root.dead_letter_routing agent which will log warning.

67
68
69

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 67

def dead_letter_routing
  parent.dead_letter_routing
end

override to se different default executor, e.g. to change it to global_fast_executor

override if different class for reference is needed

83
84
85

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 83

def default_reference_class
  Reference
end

Returns current envelope, accessible inside #on_message processing.

77
78
79

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 77

def envelope
  @envelope or raise 'envelope not set'
end

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

46
47
48
49
50
51

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 46

def on_envelope(envelope)
  @envelope = envelope
  on_message envelope.message
ensure
  @envelope = nil
end

override to add custom code invocation on internal events like :terminated, :resumed, anError.

42
43

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 42

def on_event(event)
end

override to define Actor's behaviour

Returns a result which will be used to set the Future supplied to Reference#ask.

37
38
39

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 37

def on_message(message)
  raise NotImplementedError
end

55
56
57

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 55

def pass
  core.behaviour!(Behaviour::ExecutesContext).pass envelope
end

94
95
96

# File 'lib/concurrent-ruby-edge/concurrent/actor/context.rb', line 94

def tell(message)
  reference.tell message
end

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4