Minor changes

Author: qvacua

Commons/Tests/CommonsTests/FifoCacheTest.swift

@@ -13,7 +13,7 @@ class FifoCacheTest: XCTestCase {
 
   override func setUp() {
     super.setUp()
-    self.fifo = FifoCache(count: 10, queueQos: .default)
+    self.fifo = FifoCache(count: 10)
   }
 
   func testSimpleGet() {

Neovim

@@ -8,24 +8,14 @@ public final class AsyncFuture<Element: Sendable>: Sendable {
 
   public init() {
     (self.stream, self.continuation) = AsyncStream.makeStream()
-    self.defaultValue = nil
-  }
-
-  public init(_ result: ResultType) {
-    (self.stream, self.continuation) = AsyncStream.makeStream()
-    self.defaultValue = result
   }
 
   public func yield(_ result: ResultType) {
-    guard self.defaultValue == nil else { fatalError("This should not happen!") }
-
     self.continuation.yield(result)
     self.continuation.finish()
   }
 
   public func value() async -> ResultType {
-    if let defaultValue = self.defaultValue { return defaultValue }
-
     for await result in self.stream {
       // Return the first (and only) value
       return result
@@ -38,6 +28,4 @@ public final class AsyncFuture<Element: Sendable>: Sendable {
 
   private let stream: AsyncStream<ResultType>
   private let continuation: AsyncStream<ResultType>.Continuation
-
-  private let defaultValue: ResultType?
 }

NvimApi/Sources/NvimApi/AsyncFuture.swift

@@ -143,7 +143,7 @@ public actor MsgpackRpc {
 
   // MARK: Private
 
-  private let log = Logger(subsystem: "com.qvacua.RxPack.MsgpackRpc", category: "rpc")
+  private let log = Logger(subsystem: "com.qvacua.NvimApi", category: "rpc")
 
   private var closed = false
 
@@ -159,7 +159,9 @@ public actor MsgpackRpc {
   private func startReading() async throws {
     Task.detached(priority: .high) {
       self.log.debug("Start reading")
-      guard let dataStream = await self.outPipe?.asyncData else { return }
+      guard let dataStream = await self.outPipe?.asyncData else {
+        throw Error(msg: "Could not get the async data stream")
+      }
 
       var remainderData = Data()
       var dataToUnmarshall = Data()