We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 27b72d7 + c35ef4c commit e14f1bdCopy full SHA for e14f1bd
internal/topic/topicreaderinternal/stream_reader_impl_test.go
@@ -787,7 +787,7 @@ func newTopicReaderTestEnv(t testing.TB) streamEnv {
787
stream.EXPECT().Recv().AnyTimes().DoAndReturn(env.receiveMessageHandler)
788
789
// initial data request
790
- stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: initialBufferSizeBytes})
+ stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: initialBufferSizeBytes}).MaxTimes(1)
791
792
// allow in test send data without explicit sizes
793
stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: 0}).AnyTimes()
0 commit comments