diff options
Diffstat (limited to 'xdelta3/go/src/xdelta/rstream.go')
| -rw-r--r-- | xdelta3/go/src/xdelta/rstream.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/xdelta3/go/src/xdelta/rstream.go b/xdelta3/go/src/xdelta/rstream.go index e31b0b0..67d23e6 100644 --- a/xdelta3/go/src/xdelta/rstream.go +++ b/xdelta3/go/src/xdelta/rstream.go | |||
| @@ -22,6 +22,9 @@ func WriteRstreams(t *TestGroup, desc string, seed, offset, len int64, | |||
| 22 | 22 | ||
| 23 | func writeOne(g Goroutine, seed, offset, len int64, stream io.WriteCloser, readall bool) { | 23 | func writeOne(g Goroutine, seed, offset, len int64, stream io.WriteCloser, readall bool) { |
| 24 | if !readall { | 24 | if !readall { |
| 25 | // Allow the source-read to fail or block until the process terminates. | ||
| 26 | // This behavior is reserved for the decoder, which is not required to | ||
| 27 | // read the entire source. | ||
| 25 | g.OK() | 28 | g.OK() |
| 26 | } | 29 | } |
| 27 | if offset != 0 { | 30 | if offset != 0 { |