This repository was archived by the owner on Sep 30, 2024. It is now read-only.
File tree 1 file changed +13
-5
lines changed
shared/src/api/protocol/jsonrpc2/transports
1 file changed +13
-5
lines changed Original file line number Diff line number Diff line change @@ -37,10 +37,14 @@ class WebWorkerMessageReader extends AbstractMessageReader implements MessageRea
37
37
this . fireError ( err )
38
38
}
39
39
} )
40
- worker . addEventListener ( 'error' , err => {
40
+ worker . addEventListener ( 'error' , ( err : ErrorEvent ) => {
41
41
this . fireError ( err )
42
- terminateWorker ( worker )
43
- this . fireClose ( )
42
+ if ( err . cancelable ) {
43
+ err . preventDefault ( )
44
+ } else {
45
+ terminateWorker ( worker )
46
+ this . fireClose ( )
47
+ }
44
48
} )
45
49
}
46
50
@@ -106,9 +110,13 @@ function terminateWorker(worker: Worker): void {
106
110
* `self`) if the current execution context is in a Worker. Defaults to the global scope.
107
111
*/
108
112
export function createWebWorkerMessageTransports ( worker : Worker = globalWorkerScope ( ) ) : MessageTransports {
113
+ const reader = new WebWorkerMessageReader ( worker )
114
+ const writer = new WebWorkerMessageWriter ( worker )
115
+ reader . onError ( err => console . error ( err ) )
116
+ writer . onError ( err => console . error ( err ) )
109
117
return {
110
- reader : new WebWorkerMessageReader ( worker ) ,
111
- writer : new WebWorkerMessageWriter ( worker ) ,
118
+ reader,
119
+ writer,
112
120
}
113
121
}
114
122
You can’t perform that action at this time.
0 commit comments