InTheForest/moby
1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2026-01-11 18:51:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix:close event channel when exit

Browse Source 
caller cannot close receive-only channel

Signed-off-by: vvnotw <for_vv@foxmail.com>
This commit is contained in:
vvnotw
2020-03-17 16:06:04 +08:00
parent 37defbfd9b
commit b4e6e67c4f
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
client/events.go
View File

@@ -12,8 +12,8 @@ import (
timetypes "github.com/docker/docker/api/types/time"
)
// Events returns a stream of events in the daemon. It's up to the caller to close the stream
// by cancelling the context. Once the stream has been completely read an io.EOF error will
// Events returns a stream of events in the daemon. The stream will be closed when ctx canceled
// or an error occured. Once the stream has been completely read an io.EOF error will
// be sent over the error channel. If an error is sent all processing will be stopped. It's up
// to the caller to reopen the stream in the event of an error by reinvoking this method.
func (cli *Client) Events(ctx context.Context, options types.EventsOptions) (<-chan events.Message, <-chan error) {
@@ -24,6 +24,7 @@ func (cli *Client) Events(ctx context.Context, options types.EventsOptions) (<-c
started := make(chan struct{})
go func() {
defer close(errs)
defer close(messages)
query, err := buildEventsQueryParams(cli.version, options)
if err != nil {