|
|
|
|
@ -82,3 +82,20 @@ func TestConfirmerMultipleRequestCalls(t *testing.T) { |
|
|
|
|
_, errAgain := req.Result() |
|
|
|
|
assert.Error(t, errAgain) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func TestConfirmerMultipleSetResultCalls(t *testing.T) { |
|
|
|
|
c := New() |
|
|
|
|
|
|
|
|
|
req := c.NewRequest(1 * time.Second) |
|
|
|
|
|
|
|
|
|
go func() { |
|
|
|
|
assert.NoError(t, c.SetResult(req.ID(), true)) |
|
|
|
|
assert.Error(t, c.SetResult(req.ID(), true)) |
|
|
|
|
assert.Error(t, c.SetResult(req.ID(), true)) |
|
|
|
|
assert.Error(t, c.SetResult(req.ID(), true)) |
|
|
|
|
}() |
|
|
|
|
|
|
|
|
|
res, err := req.Result() |
|
|
|
|
assert.NoError(t, err) |
|
|
|
|
assert.True(t, res) |
|
|
|
|
} |
|
|
|
|
|