commit | 5da22b92e9485c15a6b284d52cc54d6580864c99 | [log] [tgz] |
---|---|---|
author | Qi Zhao <toqizhao@gmail.com> | Thu Jan 14 17:41:25 2016 -0800 |
committer | Qi Zhao <toqizhao@gmail.com> | Thu Jan 14 17:41:25 2016 -0800 |
tree | 00b73194124c6ee45079dc4cb18b89238ec4d339 | |
parent | b24c3575360e1c3bd52fc860d7cfe8136a377392 [diff] | |
parent | 8e76d451dd39b5a194c7affeafa3be9c27559d71 [diff] |
Merge pull request #492 from iamqizhao/master Add missing trace finish on an uncommon code path
diff --git a/stream.go b/stream.go index 3ac5f6a..d8bdc16 100644 --- a/stream.go +++ b/stream.go
@@ -138,7 +138,9 @@ case <-t.Error(): // Incur transport error, simply exit. case <-s.Context().Done(): - cs.closeTransportStream(transport.ContextErr(s.Context().Err())) + err := s.Context().Err() + cs.finish(err) + cs.closeTransportStream(transport.ContextErr(err)) } }() return cs, nil