From 90804c553ec7b2e135bec82f036b8a70863d2971 Mon Sep 17 00:00:00 2001 From: cnderrauber Date: Wed, 18 Dec 2024 17:02:06 +0800 Subject: [PATCH] more relax on subscriber bitrates (#3265) --- test/singlenode_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/singlenode_test.go b/test/singlenode_test.go index 0e83fce10..5ab7c868a 100644 --- a/test/singlenode_test.go +++ b/test/singlenode_test.go @@ -785,7 +785,7 @@ func TestDataPublishSlowSubscriber(t *testing.T) { // no data should be dropped for slow subscriber that is above threshold var slowNoDropDataIndex atomic.Uint64 var drainSlowSubNotDrop atomic.Bool - slowNoDropReader := testclient.NewDataChannelReader(dataChannelSlowThreshold * 3 / 2) + slowNoDropReader := testclient.NewDataChannelReader(dataChannelSlowThreshold * 2) slowSubNotDrop.OnDataReceived = func(data []byte, sid string) { idx := binary.BigEndian.Uint64(data[len(data)-8:]) require.Equal(t, slowNoDropDataIndex.Load()+1, idx)