Skip to content

Commit

Permalink
reverting unwanted change
Browse files Browse the repository at this point in the history
  • Loading branch information
sakshi-goyal-razorpay committed Aug 31, 2022
1 parent 2c22795 commit 3ebd7bc
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions internal/stream/stream_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -204,8 +204,6 @@ func getMockSubscriber(ctx context.Context, ctrl *gomock.Controller) *mocks3.Moc
counter := 0
for {
select {
case <-cancelChan:
return
case <-reqCh:
if counter < 1 {
messages := getMockResponseMessages()
Expand All @@ -216,6 +214,8 @@ func getMockSubscriber(ctx context.Context, ctrl *gomock.Controller) *mocks3.Moc
} else {
resCh <- &metrov1.PullResponse{}
}
case <-cancelChan:
return
}
}
}()
Expand Down

0 comments on commit 3ebd7bc

Please sign in to comment.