mirror of
https://github.com/psviderski/uncloud.git
synced 2026-08-26 11:03:34 +00:00
fix: docker client PullImage
This commit is contained in:
@@ -35,12 +35,12 @@ func (cli *Client) PullImage(
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer respBody.Close()
|
|
||||||
|
|
||||||
decoder := json.NewDecoder(respBody)
|
decoder := json.NewDecoder(respBody)
|
||||||
ch := make(chan PullImageMessage)
|
ch := make(chan PullImageMessage)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
|
defer respBody.Close()
|
||||||
defer close(ch)
|
defer close(ch)
|
||||||
var jm jsonmessage.JSONMessage
|
var jm jsonmessage.JSONMessage
|
||||||
|
|
||||||
@@ -59,7 +59,7 @@ func (cli *Client) PullImage(
|
|||||||
}
|
}
|
||||||
|
|
||||||
select {
|
select {
|
||||||
case err = <-ctx.Done():
|
case <-ctx.Done():
|
||||||
ch <- PullImageMessage{Err: ctx.Err()}
|
ch <- PullImageMessage{Err: ctx.Err()}
|
||||||
return
|
return
|
||||||
default:
|
default:
|
||||||
|
|||||||
Reference in New Issue
Block a user