File tree Expand file tree Collapse file tree 1 file changed +1
-35
lines changed Expand file tree Collapse file tree 1 file changed +1
-35
lines changed Original file line number Diff line number Diff line change @@ -14,40 +14,6 @@ function findSourceMapURL(fileName) {
1414 ) ;
1515}
1616
17- function createDelayedStream (
18- stream : ReadableStream < Uint8Array >
19- ) : ReadableStream < Uint8Array > {
20- return new ReadableStream ( {
21- async start ( controller ) {
22- const reader = stream . getReader ( ) ;
23-
24- try {
25- while ( true ) {
26- const { done, value} = await reader . read ( ) ;
27- if ( done ) {
28- if ( ! controller . desiredSize === null ) {
29- controller . close ( ) ;
30- }
31- break ;
32- } else {
33- // Artificially delay between enqueuing chunks.
34- await new Promise ( resolve => setTimeout ( resolve , 10 ) ) ;
35- if ( controller . desiredSize !== null ) {
36- controller . enqueue ( value ) ;
37- }
38- }
39- }
40- } catch ( error ) {
41- if ( controller . desiredSize !== null ) {
42- controller . error ( error ) ;
43- }
44- } finally {
45- reader . releaseLock ( ) ;
46- }
47- } ,
48- } ) ;
49- }
50-
5117async function createWebSocketStream ( url ) {
5218 const ws = new WebSocket ( url ) ;
5319 ws . binaryType = 'arraybuffer' ;
@@ -83,7 +49,7 @@ async function createWebSocketStream(url) {
8349 } ,
8450 } ) ;
8551
86- return { readable : createDelayedStream ( readable ) , writable } ;
52+ return { readable, writable} ;
8753}
8854
8955let updateRoot ;
You can’t perform that action at this time.
0 commit comments