| commit | e804db2049dcb8c08e345cd585b5af577d7bd637 | [log] [tgz] |
|---|---|---|
| author | Jean de Klerk <deklerk@google.com> | Mon Dec 17 07:37:29 2018 -0800 |
| committer | Jean de Klerk <deklerk@google.com> | Mon Dec 17 16:29:36 2018 +0000 |
| tree | 9850f5639490b131e3c93d9b226025fbc2dfee04 | |
| parent | b89e82850ed08115175ea9d9b5aff94e3ac62e88 [diff] |
internal: small fix to e2e test Change-Id: I5f817a01eaae5fbf96f3a680c5c6383dbd98061e Reviewed-on: https://code-review.googlesource.com/c/36530 Reviewed-by: kokoro <noreply+kokoro@google.com> Reviewed-by: Eno Compton <enocom@google.com>
diff --git a/pubsub/internal/longtest/endtoend_test.go b/pubsub/internal/longtest/endtoend_test.go index dd1d362..8dfa55f 100644 --- a/pubsub/internal/longtest/endtoend_test.go +++ b/pubsub/internal/longtest/endtoend_test.go
@@ -267,7 +267,7 @@ prev := c.totalRecvd err := sub.Receive(ctx2, c.process) t.Logf("%s: end receive; read %d", id, c.totalRecvd-prev) - if serr, _ := status.FromError(err); serr.Code() != codes.Canceled { + if serr, _ := status.FromError(err); err != nil && serr.Code() != codes.Canceled { panic(err) } select {