Fix a race that fake execution client sends event to closed channel.

Signed-off-by: Lantao Liu <lantaol@google.com>
This commit is contained in:
Lantao Liu 2017-06-14 01:50:02 +00:00
parent 7050011faa
commit 2ae22b33b7

View File

@ -89,6 +89,7 @@ func (f *FakeExecutionClient) Stop() {
for _, client := range f.eventClients {
close(client.Events)
}
f.eventClients = nil
}
// WithEvents setup events publisher for FakeExecutionClient