File tree Expand file tree Collapse file tree 3 files changed +8
-4058
lines changed Expand file tree Collapse file tree 3 files changed +8
-4058
lines changed Original file line number Diff line number Diff line change @@ -313,7 +313,6 @@ const main = async () => {
313
313
formatting . format `${ formatting . level } :${ formatting . keys } :${ formatting . msg } ` ,
314
314
) ,
315
315
] ) ;
316
- const localhost = '127.0.0.1' ;
317
316
const key = await generateKeyHMAC ( ) ;
318
317
let socketCleanMethods = socketCleanupFactory ( ) ;
319
318
const serverCrypto = {
@@ -342,13 +341,11 @@ const main = async () => {
342
341
server . addEventListener ( events . EventQUICServerConnection . name , ( e ) =>
343
342
connectionEventProm . resolveP ( e ) ,
344
343
) ;
345
- await server . start ( {
346
- host : localhost ,
347
- } ) ;
344
+ await server . start ( { host : '127.0.0.1' } ) ;
348
345
const client = await QUICClient . createQUICClient ( {
349
- host : localhost ,
346
+ host : '127.0.0.1' ,
350
347
port : server . port ,
351
- localHost : localhost ,
348
+ localHost : '127.0.0.1' ,
352
349
crypto : {
353
350
ops : clientCrypto ,
354
351
} ,
@@ -373,11 +370,13 @@ const main = async () => {
373
370
console . error ( 'loop' ) ;
374
371
const stream = client . connection . newStream ( ) ;
375
372
const writer = stream . writable . getWriter ( ) ;
376
- const reader = stream . readable . getReader ( ) ;
377
373
await writer . write ( message ) ;
378
- await reader . read ( ) ;
379
374
await writer . close ( ) ;
380
- await reader . cancel ( ) ;
375
+ const reader = stream . readable . getReader ( ) ;
376
+ let finished = false ;
377
+ while ( ! finished ) {
378
+ finished = ( await reader . read ( ) ) . done ;
379
+ }
381
380
}
382
381
await Promise . all ( [ activeServerStreams ] ) ;
383
382
You can’t perform that action at this time.
0 commit comments