#2835

Committed 05 Oct 2014 10:16PM UTC coverage: 45.201% (-49.6%) from 94.81%

Build # #2835

Build Type

push

Committed by

Commit Message

Merge pull request #158 from obrok/promise-composition

Promise composition

Run Details

2 of 15 new or added lines in 1 file covered. (13.33%)

1514 existing lines in 84 files now uncovered.

1375 of 3042 relevant lines covered (45.2%)

0.66 hits per line

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

53.85

/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
UNCOV 8	@dead_letter_router = Core.new(parent: reference,	×
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
UNCOV 17	when message.is_a?(Array) && message.first == :spawn	×
UNCOV 18	Actor.spawn message[1], &message[2]	×
19	when message == :dead_letter_routing
20	@dead_letter_router	×
21	else
22	# ignore
23	end
24	end
25
26	def dead_letter_routing	1✔
UNCOV 27	@dead_letter_router	×
28	end
29
30	def behaviour_definition	1✔
UNCOV 31	[*Behaviour.base,	×
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 / #2835

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