docs: the shutdown comments say what happens, without the task number
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
@@ -484,7 +484,7 @@ func run() error {
|
|||||||
// Shutdown waits for in-flight requests but never cancels them, and an
|
// Shutdown waits for in-flight requests but never cancels them, and an
|
||||||
// SSE stream only ends when its client leaves. Closing the bus ends
|
// SSE stream only ends when its client leaves. Closing the bus ends
|
||||||
// every stream as shutdown begins, so the drain waits only on real work
|
// every stream as shutdown begins, so the drain waits only on real work
|
||||||
// such as an audio stream; clients reconnect to the next instance (#5293).
|
// such as an audio stream; clients reconnect to the next instance.
|
||||||
httpServer.RegisterOnShutdown(bus.Close)
|
httpServer.RegisterOnShutdown(bus.Close)
|
||||||
|
|
||||||
errCh := make(chan error, 1)
|
errCh := make(chan error, 1)
|
||||||
|
|||||||
@@ -150,7 +150,7 @@ func TestPublish_ConcurrentWritersAndSubscribers(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Close is what lets the server shut down with SSE clients connected: each
|
// Close is what lets the server shut down with SSE clients connected: each
|
||||||
// stream returns when its channel closes (#5293).
|
// stream returns when its channel closes.
|
||||||
func TestClose_EndsEverySubscription(t *testing.T) {
|
func TestClose_EndsEverySubscription(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
b := New()
|
b := New()
|
||||||
|
|||||||
Reference in New Issue
Block a user