Function TestConcurrentEncoding

pkg/msgpack/msgpack_test.go:113–145

TestConcurrentEncoding verifies thread-safety of buffer pooling

(t *testing.T)

// TestConcurrentEncoding verifies thread-safety of buffer pooling
func TestConcurrentEncoding(t *testing.T) {
	type payload struct {
		ID    int    `json:"id"`
		Value string `json:"value"`
	}

	var wg sync.WaitGroup
	concurrency := 50

	for i := 0; i < concurrency; i++ {
		wg.Add(1)
		go func(id int) {
			defer wg.Done()

			p := payload{
				ID:    id,
				Value: "test value",
			}

			result, err := EncodeMsgPack(p)
			if err != nil {
				t.Errorf("EncodeMsgPack() failed for ID %d: %v", id, err)
				return
			}

			if len(result) == 0 {
				t.Errorf("EncodeMsgPack() returned empty result for ID %d", id)
			}
		}(i)
	}

	wg.Wait()
}

// BenchmarkEncodeMsgPack benchmarks encoding performance
func BenchmarkEncodeMsgPack(b *testing.B) {