File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -171,9 +171,9 @@ pub fn Blocking(comptime S: type, comptime WSH: type) type {
171
171
thread_pool .stop ();
172
172
}
173
173
174
- pub fn stop (_ : * const Self ) void {
175
- // noop, exists for compatibility with NonBlocking worker
176
- // we'll stop when the http.Server shutdown the listening socket.
174
+ pub fn stop (self : * const Self ) void {
175
+ // The HTTP server will stop when the http.Server shutdown the listening socket.
176
+ self . websocket . shutdown ();
177
177
}
178
178
179
179
// Called in a worker thread. `thread_buf` is a thread-specific buffer that
@@ -530,6 +530,7 @@ pub fn NonBlocking(comptime S: type, comptime WSH: type) type {
530
530
log .err ("Failed to add monitor to listening socket: {}" , .{err });
531
531
return ;
532
532
};
533
+ defer self .websocket .shutdown ();
533
534
534
535
var now = timestamp (0 );
535
536
var last_timeout = now ;
You can’t perform that action at this time.
0 commit comments