fix streaming bug

awxkee · Oct 23, 2022 · 9e1e969 · 9e1e969
1 parent e0a3b71
commit 9e1e969
Showing 1 changed file with 2 additions and 12 deletions.
diff --git a/Sources/bzip2.swift/BZip2.swift b/Sources/bzip2.swift/BZip2.swift
@@ -111,12 +111,7 @@ public class BZip2 {
             readData = src.read(srcBuffer.assumingMemoryBound(to: UInt8.self), maxLength: Int(BZipCompressionBufferSize))
             compressedSize += Int64(readData)
             if readData == -1 {
-                free(srcBuffer)
-                free(dstBuffer)
-                src.close()
-                dst.close()
-                BZ2_bzDecompressEnd(&stream)
-                throw BZip2InvalidInputStreamError()
+                break
             }
             stream.avail_in = UInt32(readData)
             stream.next_in = srcBuffer.bindMemory(to: CChar.self, capacity: Int(BZipCompressionBufferSize))
@@ -187,12 +182,7 @@ public class BZip2 {
             readData = src.read(srcBuffer, maxLength: Int(BZipCompressionBufferSize))
             compressedSize += Int64(readData)
             if readData == -1 {
-                free(srcBuffer)
-                free(dstBuffer)
-                src.close()
-                dst.close()
-                BZ2_bzCompressEnd(&stream)
-                throw BZip2InvalidInputStreamError()
+                break
             }
             stream.next_in = srcBuffer.assumingMemoryBound(to: CChar.self)
             stream.avail_in = UInt32(readData)