add _sendRegistrationEvent

Author: cevr

packages/core/src/system.ts

@@ -66,6 +66,12 @@ export interface ActorSystem<T extends ActorSystemInfo>
    * @internal
    */
   _unregister: (actorRef: AnyActorRef) => void;
+  /**
+   * @internal
+   */
+  _sendRegistrationEvent: (
+    event: RegistrationEvent<T['actors'][keyof T['actors']]>
+  ) => void;
   /**
    * @internal
    */
@@ -179,13 +185,10 @@ export function createSystem<T extends ActorSystemInfo>(
       children.set(sessionId, actorRef);
       const systemId = reverseKeyedActors.get(actorRef);
       if (systemId !== undefined) {
-        const event = {
+        system._sendRegistrationEvent({
           type: `@xstate.actor.register`,
           systemId: systemId as string,
           actorRef: actorRef as T['actors'][keyof T['actors']]
-        } as const;
-        registrationObservers.forEach((listener) => {
-          listener.next?.(event);
         });
       }
       return sessionId;
@@ -197,14 +200,11 @@ export function createSystem<T extends ActorSystemInfo>(
       if (systemId !== undefined) {
         keyedActors.delete(systemId);
         reverseKeyedActors.delete(actorRef);
-        const event = {
+        system._sendRegistrationEvent({
           type: `@xstate.actor.unregister`,
           systemId: systemId as string,
           actorRef: actorRef as T['actors'][keyof T['actors']]
-        } as const;
-        registrationObservers.forEach((listener) => {
-          listener.next?.(event);
-        });
+        } as const);
       }
     },
     get: (systemId) => {
@@ -268,6 +268,9 @@ export function createSystem<T extends ActorSystemInfo>(
         (observer) => observer.next?.(resolvedInspectionEvent)
       );
     },
+    _sendRegistrationEvent: (event) => {
+      registrationObservers.forEach((observer) => observer.next?.(event));
+    },
     _relay: (source, target, event) => {
       system._sendInspectionEvent({
         type: '@xstate.event',