Skip to content

Commit c35ef4c

Browse files
committed
fix flack send initial size
1 parent 27b72d7 commit c35ef4c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/topic/topicreaderinternal/stream_reader_impl_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -787,7 +787,7 @@ func newTopicReaderTestEnv(t testing.TB) streamEnv {
787787
stream.EXPECT().Recv().AnyTimes().DoAndReturn(env.receiveMessageHandler)
788788

789789
// initial data request
790-
stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: initialBufferSizeBytes})
790+
stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: initialBufferSizeBytes}).MaxTimes(1)
791791

792792
// allow in test send data without explicit sizes
793793
stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: 0}).AnyTimes()

0 commit comments

Comments
 (0)