non-blocking send

observIQ · Jul 1, 2024 · 578e3ec · 578e3ec
1 parent 0d0b5e3
commit 578e3ec
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/opamp/observiq/measurements_test.go b/opamp/observiq/measurements_test.go
@@ -41,7 +41,11 @@ func TestMeasurementsSender(t *testing.T) {
 		client := mocks.NewMockOpAMPClient(t)
 		client.On("SendCustomMessage", mock.Anything).Run(func(args mock.Arguments) {
 			cm := args.Get(0).(*protobufs.CustomMessage)
-			dataChan <- cm.Data
+			select {
+			case dataChan <- cm.Data:
+			default:
+			}
+
 		}).Return(make(chan struct{}), nil)
 
 		mp := metric.NewMeterProvider()
@@ -88,7 +92,10 @@ func TestMeasurementsSender(t *testing.T) {
 		client := mocks.NewMockOpAMPClient(t)
 		client.On("SendCustomMessage", mock.Anything).Run(func(args mock.Arguments) {
 			cm := args.Get(0).(*protobufs.CustomMessage)
-			dataChan <- cm.Data
+			select {
+			case dataChan <- cm.Data:
+			default:
+			}
 		}).Return(make(chan struct{}), nil)
 
 		mp := metric.NewMeterProvider()