bugfix: return the context error during event subscribe

Signed-off-by: Wei Fu <fuweid89@gmail.com>
This commit is contained in:
Wei Fu 2018-10-24 15:28:55 +08:00
parent a4b6522e11
commit 15a761c035

View File

@ -110,6 +110,9 @@ func (e *eventRemote) Subscribe(ctx context.Context, filters ...string) (ch <-ch
Event: ev.Event, Event: ev.Event,
}: }:
case <-ctx.Done(): case <-ctx.Done():
if cerr := ctx.Err(); cerr != context.Canceled {
errq <- cerr
}
return return
} }
} }