...
This commit is contained in:
parent
a210e0c977
commit
b4d8eaa0fe
1 changed files with 5 additions and 3 deletions
|
|
@ -55,9 +55,11 @@ func NewStreamDecompressor(constructor func(io.Reader) (io.ReadCloser, error), o
|
|||
if iter_err != nil {
|
||||
return iter_err
|
||||
}
|
||||
_, iter_err = pipe_w.Write(chunk)
|
||||
if iter_err != nil {
|
||||
return iter_err
|
||||
if len(chunk) > 0 {
|
||||
_, iter_err = pipe_w.Write(chunk)
|
||||
if iter_err != nil {
|
||||
return iter_err
|
||||
}
|
||||
}
|
||||
if is_last {
|
||||
pipe_w.CloseWithError(io.EOF)
|
||||
|
|
|
|||
Loading…
Reference in a new issue