bugfix: return the context error during event subscribe

fuweid · fuweid · commit 15a761c0352c · 2018-10-24T19:25:57.000+08:00
Signed-off-by: Wei Fu &lt;fuweid89@gmail.com&gt;
diff --git a/events.go b/events.go
@@ -110,6 +110,9 @@ func (e *eventRemote) Subscribe(ctx context.Context, filters ...string) (ch <-ch
 				Event:     ev.Event,
 			}:
 			case <-ctx.Done():
+				if cerr := ctx.Err(); cerr != context.Canceled {
+					errq <- cerr
+				}
 				return
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,9 @@ func (e *eventRemote) Subscribe(ctx context.Context, filters ...string) (ch <-ch`
`110`	`110`	`Event: ev.Event,`
`111`	`111`	`}:`
`112`	`112`	`case <-ctx.Done():`
	`113`	`+ if cerr := ctx.Err(); cerr != context.Canceled {`
	`114`	`+ errq <- cerr`
	`115`	`+ }`
`113`	`116`	`return`
`114`	`117`	`}`
`115`	`118`	`}`