Function TestQueue_ConcurrentRegisterHandler

internal/base/queue/queue_test.go:196–212

(t *testing.T)

}

func TestQueue_ConcurrentRegisterHandler(t *testing.T) {
	q := New[*testMessage]("test", 10)
	defer q.Close()

	// Concurrently register handlers - should not race
	var wg sync.WaitGroup
	for range 10 {
		wg.Add(1)
		go func() {
			defer wg.Done()
			q.RegisterHandler(func(ctx context.Context, msg *testMessage) error {
				return nil
			})
		}()
	}
	wg.Wait()
}

// TestQueue_SendCloseRace is a regression test for the race condition between
// Send and Close. Without proper synchronization, concurrent Send and Close