Skip to content

Instantly share code, notes, and snippets.

@romainbriche
Forked from sooop/StreamReader.swift
Created June 8, 2018 00:27
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save romainbriche/994f2bce266448bbaea127d460e5c3c9 to your computer and use it in GitHub Desktop.
Save romainbriche/994f2bce266448bbaea127d460e5c3c9 to your computer and use it in GitHub Desktop.
Read a large text file line by line - Swift 3
import Foundation
class StreamReader {
let encoding: String.Encoding
let chunkSize: Int
let fileHandle: FileHandle
var buffer: Data
let delimPattern : Data
var isAtEOF: Bool = false
init?(url: URL, delimeter: String = "\n", encoding: String.Encoding = .utf8, chunkSize: Int = 4096)
{
guard let fileHandle = try? FileHandle(forReadingFrom: url) else { return nil }
self.fileHandle = fileHandle
self.chunkSize = chunkSize
self.encoding = encoding
buffer = Data(capacity: chunkSize)
delimPattern = delimeter.data(using: .utf8)!
}
deinit {
fileHandle.closeFile()
}
func rewind() {
fileHandle.seek(toFileOffset: 0)
buffer.removeAll(keepingCapacity: true)
isAtEOF = false
}
func nextLine() -> String? {
if isAtEOF { return nil }
repeat {
if let range = buffer.range(of: delimPattern, options: [], in: buffer.startIndex..<buffer.endIndex) {
let subData = buffer.subdata(in: buffer.startIndex..<range.lowerBound)
let line = String(data: subData, encoding: encoding)
buffer.replaceSubrange(buffer.startIndex..<range.upperBound, with: [])
return line
} else {
let tempData = fileHandle.readData(ofLength: chunkSize)
if tempData.count == 0 {
isAtEOF = true
return (buffer.count > 0) ? String(data: buffer, encoding: encoding) : nil
}
buffer.append(tempData)
}
} while true
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment