deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

The loopback NATS client can not leak goroutines.

Browse source
This commit is contained in:
Joachim Bauch 2025-12-09 10:40:54 +01:00
commit f7b9224bda
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
1 changed files with 16 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

36
natsclient_loopback_test.go
View file

@ -63,34 +63,30 @@ func CreateLoopbackNatsClientForTest(t *testing.T) NatsClient {
return result
}
func TestLoopbackNatsClient_Subscribe(t *testing.T) { // nolint:paralleltest
ensureNoGoroutinesLeak(t, func(t *testing.T) {
client := CreateLoopbackNatsClientForTest(t)
func TestLoopbackNatsClient_Subscribe(t *testing.T) {
t.Parallel()
testNatsClient_Subscribe(t, client)
})
client := CreateLoopbackNatsClientForTest(t)
testNatsClient_Subscribe(t, client)
}
func TestLoopbackClient_PublishAfterClose(t *testing.T) { // nolint:paralleltest
ensureNoGoroutinesLeak(t, func(t *testing.T) {
client := CreateLoopbackNatsClientForTest(t)
func TestLoopbackClient_PublishAfterClose(t *testing.T) {
t.Parallel()
testNatsClient_PublishAfterClose(t, client)
})
client := CreateLoopbackNatsClientForTest(t)
testNatsClient_PublishAfterClose(t, client)
}
func TestLoopbackClient_SubscribeAfterClose(t *testing.T) { // nolint:paralleltest
ensureNoGoroutinesLeak(t, func(t *testing.T) {
client := CreateLoopbackNatsClientForTest(t)
func TestLoopbackClient_SubscribeAfterClose(t *testing.T) {
t.Parallel()
testNatsClient_SubscribeAfterClose(t, client)
})
client := CreateLoopbackNatsClientForTest(t)
testNatsClient_SubscribeAfterClose(t, client)
}
func TestLoopbackClient_BadSubjects(t *testing.T) { // nolint:paralleltest
ensureNoGoroutinesLeak(t, func(t *testing.T) {
client := CreateLoopbackNatsClientForTest(t)
func TestLoopbackClient_BadSubjects(t *testing.T) {
t.Parallel()
testNatsClient_BadSubjects(t, client)
})
client := CreateLoopbackNatsClientForTest(t)
testNatsClient_BadSubjects(t, client)
}