Skip to content

Commit 3a32d3e

Browse files
committed
Adding supervision and restarts
removing Context module in favor of Context class
1 parent 838c4dc commit 3a32d3e

File tree

13 files changed

+403
-147
lines changed

13 files changed

+403
-147
lines changed

doc/actor/quick.in.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
class Counter
22
# Include context of an actor which gives this class access to reference and other information
3-
# about the actor, see CoreDelegations.
3+
# about the actor, see PublicDelegations.
44
include Concurrent::Actor::Context
55

66
# use initialize as you wish

doc/actor/quick.out.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
class Counter
22
# Include context of an actor which gives this class access to reference and other information
3-
# about the actor, see CoreDelegations.
3+
# about the actor, see PublicDelegations.
44
include Concurrent::Actor::Context
55

66
# use initialize as you wish

lib/concurrent/actor.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,15 @@
44
require 'concurrent/logging'
55

66
module Concurrent
7+
# TODO https://github.com/celluloid/celluloid/wiki/Supervision-Groups
78

89
# {include:file:doc/actor/main.md}
910
module Actor
1011

1112
require 'concurrent/actor/type_check'
1213
require 'concurrent/actor/errors'
13-
require 'concurrent/actor/core_delegations'
14+
require 'concurrent/actor/public_delegations'
15+
require 'concurrent/actor/internal_delegations'
1416
require 'concurrent/actor/envelope'
1517
require 'concurrent/actor/reference'
1618
require 'concurrent/actor/core'

lib/concurrent/actor/ad_hoc.rb

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,7 @@ module Actor
66
# # this block has to return proc defining #on_message behaviour
77
# -> message { where.tell message }
88
# end
9-
class AdHoc
10-
include Context
9+
class AdHoc < Context
1110
def initialize(*args, &initializer)
1211
@on_message = Type! initializer.call(*args), Proc
1312
end

0 commit comments

Comments
 (0)