in Packages/ClientRuntime/Sources/PrimitiveTypeExtensions/Data+Extensions.swift [12:34]
init(reading inputStream: InputStream) throws {
self.init()
inputStream.open()
defer {
inputStream.close()
}
let bufferSize = 1024
let buffer = UnsafeMutablePointer<UInt8>.allocate(capacity: bufferSize)
defer {
buffer.deallocate()
}
while inputStream.hasBytesAvailable {
let read = inputStream.read(buffer, maxLength: bufferSize)
if read < 0 {
throw inputStream.streamError!
} else if read == 0 {
// EOF
break
}
self.append(buffer, count: read)
}
}