#2764

Committed 08 Dec 2014 03:40PM UTC coverage: 91.388% (-0.4%) from 91.753%

Build # #2764

Build Type

push

Committed by

Commit Message

Merge pull request #201 from rkday/fallback_handling

Posting to a shutdown thread pool - JRuby consistency and better naming

Run Details

18 of 26 new or added lines in 5 files covered. (69.23%)

212 existing lines in 36 files now uncovered.

2812 of 3077 relevant lines covered (91.39%)

369.8 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

92.31

/lib/concurrent/actor/root.rb

module Concurrent
  module Actor
    # implements the root actor
    class Root < AbstractContext

      def initialize
        # noinspection RubyArgCount
        @dead_letter_router = Core.new(parent:    reference,
                                       class:     DefaultDeadLetterHandler,
                                       supervise: true,
                                       name:      :default_dead_letter_handler).reference
      end

      # to allow spawning of new actors, spawn needs to be called inside the parent Actor
      def on_message(message)
        case
        when message.is_a?(Array) && message.first == :spawn
          Actor.spawn message[1], &message[2]
        when message == :dead_letter_routing
          @dead_letter_router
        else
          # ignore
        end
      end

      def dead_letter_routing
        @dead_letter_router
      end

      def behaviour_definition
        [*Behaviour.base,
         [Behaviour::Supervising, [:reset!, :one_for_one]],
         *Behaviour.user_messages(:just_log)]
      end
    end
  end
end

1	module Concurrent	1✔
2	module Actor	1✔
3	# implements the root actor
4	class Root < AbstractContext	1✔
5
6	def initialize	1✔
7	# noinspection RubyArgCount
8	@dead_letter_router = Core.new(parent: reference,	1✔
9	class: DefaultDeadLetterHandler,
10	supervise: true,
11	name: :default_dead_letter_handler).reference
12	end
13
14	# to allow spawning of new actors, spawn needs to be called inside the parent Actor
15	def on_message(message)	1✔
16	case
17	when message.is_a?(Array) && message.first == :spawn	140✔
18	Actor.spawn message[1], &message[2]	140✔
19	when message == :dead_letter_routing
UNCOV 20	@dead_letter_router	×
21	else
22	# ignore
23	end
24	end
25
26	def dead_letter_routing	1✔
27	@dead_letter_router	10✔
28	end
29
30	def behaviour_definition	1✔
31	[*Behaviour.base,	1✔
32	[Behaviour::Supervising, [:reset!, :one_for_one]],
33	*Behaviour.user_messages(:just_log)]
34	end
35	end
36	end
37	end

ruby-concurrency / concurrent-ruby / #2764

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous