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.
1 parent ba719e6 commit 5d9300dCopy full SHA for 5d9300d
internal/topic/topicreaderinternal/stream_reader_impl_test.go
@@ -115,7 +115,6 @@ func TestTopicStreamReaderImpl_CommitStolen(t *testing.T) {
115
116
lastOffset := e.partitionSession.lastReceivedMessageOffset()
117
const dataSize = 4
118
-
119
// request new data portion
120
readRequestReceived := make(empty.Chan)
121
e.stream.EXPECT().Send(&rawtopicreader.ReadRequest{BytesSize: dataSize * 2}).Do(func(_ interface{}) {
0 commit comments