@actor-system/core
Advanced tools
@@ -12,2 +12,3 @@ import { createPath, resolveActorPath, parsePath } from '../__bundle__/shared/dist/path.js'; | ||
| import { EventStream } from '../event-stream/event-stream.js'; | ||
| import { lifecycleEvent } from '../actor-event.js'; | ||
@@ -171,2 +172,3 @@ const defaultScheduler = PriorityScheduler.create(); | ||
| await actor._stopChildren(); | ||
| this.eventStream._publish(lifecycleEvent(actor.self, "Stopped")); | ||
| // Unwatch all actors we were watching | ||
@@ -202,2 +204,3 @@ actor._unwatchAll(); | ||
| actor._receiveSignal(preRestart); | ||
| this.eventStream._publish(lifecycleEvent(actor.self, "Restarted")); | ||
| } | ||
@@ -204,0 +207,0 @@ /** @internal */ |
@@ -35,6 +35,5 @@ import { generateMonotonicULID } from '../__bundle__/shared/dist/monotonicULID.js'; | ||
| this.#resolveShutdown = resolve; | ||
| // Emit lifecycle event | ||
| this.system.eventStream._publish(lifecycleEvent(this.self, "Started")); | ||
| } | ||
| _initializeBehavior(initialBehavior) { | ||
| this.system.eventStream._publish(lifecycleEvent(this.self, "Started")); | ||
| const unfolded = unfold(initialBehavior, this); | ||
@@ -63,3 +62,2 @@ switch (unfolded._tag) { | ||
| this.system._stopActor(this); | ||
| this.system.eventStream._publish(lifecycleEvent(this.self, "Stopped")); | ||
| return; | ||
@@ -69,3 +67,2 @@ } | ||
| this.system._restartActor(this, control._checkpoint); | ||
| this.system.eventStream._publish(lifecycleEvent(this.self, "Restarted")); | ||
| return; | ||
@@ -72,0 +69,0 @@ } |
+1
-1
| { | ||
| "name": "@actor-system/core", | ||
| "version": "0.0.8", | ||
| "version": "0.0.9", | ||
| "type": "module", | ||
@@ -5,0 +5,0 @@ "scripts": { |
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
93631
-0.01%