@@ -102,11 +102,11 @@ func TestAsyncBatchNoWaitTime(t *testing.T) {
102102 // mock SQS calls
103103 mockSQSClient := new (mockSQSClient )
104104 mockSQSClient .On ("SendMessageBatch" ,
105- mock .AnythingOfType ("*context.emptyCtx " ), mock .AnythingOfType ("*sqs.SendMessageBatchInput" )).
105+ mock .AnythingOfType ("todoCtx " ), mock .AnythingOfType ("*sqs.SendMessageBatchInput" )).
106106 Return (nil , nil ).
107107 Times (numSqsCalls )
108108 mockSQSClient .On ("DeleteMessageBatch" ,
109- mock .AnythingOfType ("*context.emptyCtx " ), mock .AnythingOfType ("*sqs.DeleteMessageBatchInput" )).
109+ mock .AnythingOfType ("todoCtx " ), mock .AnythingOfType ("*sqs.DeleteMessageBatchInput" )).
110110 Return (nil , nil ).
111111 Times (numSqsCalls )
112112
@@ -208,15 +208,15 @@ func TestAsyncBatchWithWaitTime(t *testing.T) {
208208 // mock SQS calls
209209 mockSQSClient := new (mockSQSClient )
210210 mockSQSClient .On ("SendMessageBatch" ,
211- mock .AnythingOfType ("*context.emptyCtx " ),
211+ mock .AnythingOfType ("todoCtx " ),
212212 mock .AnythingOfType ("*sqs.SendMessageBatchInput" )).
213213 Return (nil , nil ).
214214 Maybe (). // flexible no. of calls
215215 Run (func (args mock.Arguments ) { // hook to inspect and record batch size
216216 recordBatchSize (len (args .Get (1 ).(* sqs.SendMessageBatchInput ).Entries ))
217217 })
218218 mockSQSClient .On ("DeleteMessageBatch" ,
219- mock .AnythingOfType ("*context.emptyCtx " ),
219+ mock .AnythingOfType ("todoCtx " ),
220220 mock .AnythingOfType ("*sqs.DeleteMessageBatchInput" )).
221221 Return (nil , nil ).
222222 Maybe (). // flexible no. of calls
0 commit comments