File tree Expand file tree Collapse file tree 1 file changed +10
-3
lines changed
internal/js/modules/k6/experimental/websockets Expand file tree Collapse file tree 1 file changed +10
-3
lines changed Original file line number Diff line number Diff line change @@ -501,18 +501,25 @@ func (w *webSocket) readPump(wg *sync.WaitGroup) {
501
501
}
502
502
503
503
var closeErr * websocket.CloseError
504
+ var code int
505
+ var reason string
504
506
if errors .As (err , & closeErr ) {
505
- w . closeCode = closeErr .Code
506
- w . closeReason = closeErr .Text
507
+ code = closeErr .Code
508
+ reason = closeErr .Text
507
509
}
508
510
509
511
if ! websocket .IsUnexpectedCloseError (err , websocket .CloseNormalClosure , websocket .CloseGoingAway ) {
510
512
err = nil
511
513
}
512
514
515
+ errLocal := err
513
516
w .tq .Queue (func () error {
517
+ if code != 0 {
518
+ w .closeCode = code
519
+ w .closeReason = reason
520
+ }
514
521
_ = w .conn .Close ()
515
- return w .connectionClosedWithError (err )
522
+ return w .connectionClosedWithError (errLocal )
516
523
})
517
524
return
518
525
}
You can’t perform that action at this time.
0 commit comments