@@ -35,9 +35,6 @@ export const fromWorkerfiedActor = (
3535 worker : Worker
3636) : WorkerActorLogic < EventObject , WorkerInput > => ( {
3737 config : Worker ,
38-
39-
40-
4138
4239 start : ( state , actorScope ) => {
4340 const { self, system } = actorScope ;
@@ -49,7 +46,12 @@ export const fromWorkerfiedActor = (
4946 } ;
5047
5148 worker . addEventListener ( 'message' , ( event ) => {
52- console . log ( 'Message received from worker --> ' , event , event . data . type == WORKER_EVENTS . PROXY_EVENT , WORKER_EVENTS . PROXY_EVENT ) ;
49+ console . log (
50+ 'Message received from worker --> ' ,
51+ event ,
52+ event . data . type == WORKER_EVENTS . PROXY_EVENT ,
53+ WORKER_EVENTS . PROXY_EVENT
54+ ) ;
5355 const eventPayload = event . data ;
5456 if ( eventPayload . type === WORKER_EVENTS . STATE_SNAPSHOT ) {
5557 const eventFromWorker = eventPayload as STATE_SNAPSHOT_EVENT ;
@@ -58,30 +60,25 @@ export const fromWorkerfiedActor = (
5860 }
5961
6062 if ( eventPayload . type === WORKER_EVENTS . PROXY_EVENT ) {
61-
6263 const proxyEvent = eventPayload as ProxyEvent ;
6364 const targetActorId = proxyEvent . data . to ;
6465 const targetEvent = proxyEvent . data . event ;
6566 const isToParent = targetActorId === 'parent' ;
6667 console . log ( 'Proxy event received from worker to' , targetActorId , targetEvent , isToParent ) ;
6768
68-
6969 if ( isToParent && self . _parent ) {
7070 console . log ( 'Relaying to parent' , proxyEvent . data ) ;
7171 self . _parent . send ( proxyEvent . data . event ) ;
7272 return state ;
7373 }
7474 if ( ! isToParent ) {
7575 const targetActor = system . get ( proxyEvent . data . to ) ;
76- console . log ( 'Relaying to system actor' , proxyEvent . data , targetActor , system , self ) ;
77- if ( targetActor ) {
76+ console . log ( 'Relaying to system actor' , proxyEvent . data , targetActor , system , self ) ;
77+ if ( targetActor ) {
7878 targetActor . send ( proxyEvent . data . event ) ;
7979 }
8080 return state ;
8181 }
82-
83-
84-
8582 }
8683 } ) ;
8784
@@ -103,8 +100,6 @@ export const fromWorkerfiedActor = (
103100 } ;
104101 }
105102
106-
107-
108103 if ( event . type == WORKER_EVENTS . STATE_SNAPSHOT ) {
109104 const snapshot = ( event as STATE_SNAPSHOT_EVENT ) . data . snapshot as AnyMachineSnapshot ;
110105 return {
0 commit comments