DispatchIO bug linux

reader.swift

import CoreFoundation
import Dispatch
import Foundation

let pipe = Pipe()
let queue = DispatchQueue(label: "readQueue")
let source = DispatchIO(type: .stream, fileDescriptor: pipe.fileHandleForReading.fileDescriptor,
                        queue: queue, cleanupHandler: {code in
                            print("Source spent: \(code)")
                        })
let writer = Process()

source.setLimit(lowWater: 101)

writer.launchPath = "/path/to/writer"
writer.standardOutput = pipe
writer.terminationHandler = {process in
    print("writer done")
}

func readFromSource() {
    source.read(offset: 0, length: 101, queue: queue) {done, data, code in
        guard let data = data, data.count > 0 else {
            print("No data, reader probably closed")

            if done && code == 0 {
                // EOF reached
                print("Reader done")

                exit(0)
            }

            print("Not done?")
          
            return
        }

        print("Read \(data.count) bytes")
        readFromSource()
    }
}

readFromSource()

writer.launch()

CFRunLoopRun()

writer.swift

for i in 0..<100_000 {
    print("This is a test")
}