diff --git a/eventqueue/eventqueue_test.go b/eventqueue/eventqueue_test.go index ede0971..70c3ecd 100644 --- a/eventqueue/eventqueue_test.go +++ b/eventqueue/eventqueue_test.go @@ -107,7 +107,7 @@ func TestPullBlocksUntilAvailable(t *testing.T) { ctx, cancel := context.WithTimeout(context.Background(), 1*time.Millisecond) defer cancel() - if _, err := q.Pull(ctx); err != nil { + if _, err := q.Pull(ctx); err == nil { t.Fatal("Pull => expected timeout error, got nil") }