go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

Fix double close

Browse Source
This commit is contained in:
Asim 2016-06-03 11:08:58 +01:00
parent 702072f177
commit 34365812d8
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
transport/mock/mock.go
View File

@ -63,7 +63,12 @@ func (ms *mockSocket) Send(m *transport.Message) error {
}
func (ms *mockSocket) Close() error {
close(ms.exit)
select {
case <-ms.exit:
return nil
default:
close(ms.exit)
}
return nil
}
@ -72,7 +77,12 @@ func (m *mockListener) Addr() string {
}
func (m *mockListener) Close() error {
close(m.exit)
select {
case <-m.exit:
return nil
default:
close(m.exit)
}
return nil
}