Do not miss source stream being consumed just because of errors

neicnordic · Jan 19, 2024 · 12abe57 · 12abe57
1 parent 27ae850
commit 12abe57
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/streaming/in.go b/streaming/in.go
@@ -373,6 +373,8 @@ func (c *crypt4GHInternalReader) fillBuffer() error {
 	// reader should be positioned before the needed segment now
 
 	read, err := io.ReadFull(c.reader, encryptedSegmentBytes)
+	c.sourcePos += int64(read)
+
 	if err != nil && err != io.ErrUnexpectedEOF {
 		return err
 	}
@@ -391,7 +393,6 @@ func (c *crypt4GHInternalReader) fillBuffer() error {
 		return err
 	}
 	c.lastDecryptedSegment = neededSegment
-	c.sourcePos += int64(read)
 
 	// Keep track of how much data is directly available