(NS)StreamDelegate写入已关闭OutputStream无报错：静默写入失败咨询

这确实是OutputStream在Apple平台（iOS/macOS等）上的一个容易踩的坑——当流已经被关闭后，调用写入方法既不会抛出异常，也不会触发代理的错误事件，只是默默地执行失败，数据根本不会落到文件里。结合你给出的初始化代码，我来分享几个解决思路：

核心原因 #

底层实现里，关闭后的流会把内部的文件写入通道置为无效，但上层的write API并没有做显式的错误抛出，只是返回一个代表失败的-1值，很多开发者如果没注意这个返回值，就会误以为写入成功了。

解决方案 #

1. 每次写入前检查流的状态 #

在执行写入操作前，先判断流的streamStatus是否为.open，如果不是就直接拦截写入，或者根据业务逻辑重新打开流：

func safeWrite(_ data: Data) {
    // 先检查流是否处于打开状态
    guard self.outputStream.streamStatus == .open else {
        print("警告：流已关闭或未初始化，无法写入数据")
        // 这里可以根据需求选择重新打开流，或者抛出自定义错误
        return
    }
    
    // 执行写入，并检查返回值
    let bytesWritten = data.withUnsafeBytes { buffer in
        self.outputStream.write(buffer.baseAddress!.assumingMemoryBound(to: UInt8.self), maxLength: data.count)
    }
    
    // 处理写入失败的情况
    if bytesWritten < 0 {
        if let error = self.outputStream.streamError {
            print("写入失败，错误信息：\(error.localizedDescription)")
        } else {
            print("写入失败，未知错误")
        }
    }
}

2. 用代理维护流的状态标记 #

在你的代理方法里，监听流的打开、关闭、错误事件，维护一个本地的状态标记，后续写入时直接检查这个标记，比每次读取streamStatus更直观：

private var isStreamActive = false

func stream(_ aStream: Stream, handle eventCode: Stream.Event) {
    switch eventCode {
    case .openCompleted:
        isStreamActive = true
        print("流已成功打开")
    case .endEncountered:
        isStreamActive = false
        print("流已正常结束")
        self.outputStream.close()
        self.outputStream.remove(from: RunLoop.current, forMode: .default)
    case .errorOccurred:
        isStreamActive = false
        if let error = aStream.streamError {
            print("流发生错误：\(error.localizedDescription)")
        }
        self.outputStream.close()
        self.outputStream.remove(from: RunLoop.current, forMode: .default)
    // 处理其他事件...
    default:
        break
    }
}

// 安全写入方法
func writeText(_ text: String) {
    guard isStreamActive else {
        print("流未激活，写入操作被取消")
        return
    }
    guard let data = text.data(using: .utf8) else {
        print("文本转Data失败")
        return
    }
    safeWrite(data) // 调用上面的安全写入方法
}

3. 封装流操作类，统一管理状态 #

把OutputStream的打开、关闭、写入全部封装到一个自定义类里，对外只暴露简洁的写入接口，内部统一处理状态检查和错误，避免外部代码直接操作流导致的状态混乱。

重要提醒 #

千万不要忽略write方法的返回值！即使流处于打开状态，也可能因为磁盘空间不足、文件权限问题等导致写入失败，返回值为-1时，一定要通过streamError获取具体的错误原因，这对排查问题非常关键。

内容的提问来源于stack exchange，提问作者bauerMusic