Commit89e9f95

committed

handle deadline exceeded in drain

1 parent7c198a6 commit89e9f95Copy full SHA for 89e9f95

File tree

-0

lines changed

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -170,6 +170,10 @@ func drainContext(ctx context.Context, src io.Reader, bufSize int64) error {`
`170`	`170`	`ifxerrors.Is(err,io.EOF) {`
`171`	`171`	`returnnil`
`172`	`172`	`}`
	`173`	`+// It's OK if the context is canceled.`
	`174`	`+ifxerrors.Is(err,context.DeadlineExceeded) {`
	`175`	`+returnnil`
	`176`	`+}`
`173`	`177`	`returnerr`
`174`	`178`	`}`
`175`	`179`	`}`

Comments

(0)