chore: fix typo

This commit is contained in:
chloefeal
2024-12-25 23:06:33 +08:00
parent a388c1f39d
commit 852a8d8746
11 changed files with 21 additions and 21 deletions

View File

@@ -121,7 +121,7 @@ func TestProcessBlockConsumerQuitAfterSend(t *testing.T) {
require.Equal(t, mockBeat, beat)
// Instead of sending nil to the consumer's error channel, close the
// quit chanel.
// quit channel.
close(quitChan)
// Assert ProcessBlock returned nil.

View File

@@ -120,7 +120,7 @@ func TestDispatchSequential(t *testing.T) {
// prevConsumer specifies the previous consumer that was called.
var prevConsumer string
// Mock the ProcessBlock on consumers to reutrn immediately.
// Mock the ProcessBlock on consumers to return immediately.
consumer1.On("ProcessBlock", mockBeat).Return(nil).Run(
func(args mock.Arguments) {
// Check the order of the consumers.
@@ -260,7 +260,7 @@ func TestDispatchBlocks(t *testing.T) {
b.RegisterQueue([]Consumer{consumer})
// Mock the consumer to return nil error on ProcessBlock. This
// implictly asserts that the step `notifyQueues` is successfully
// implicitly asserts that the step `notifyQueues` is successfully
// reached in the `dispatchBlocks` method.
consumer.On("ProcessBlock", mock.Anything).Return(nil).Once()