Adopted new condensed API

Author: agnosticdev

Sources/SwiftNetwork/Protocols/ManyToManyProtocol.swift

@@ -1632,6 +1632,16 @@ extension HeterogeneousManyToManyProtocolHandler where SecondaryFlow: AutomaticU
         guard let flow = self.secondaryFlow(for: flowID) else { throw NetworkError.posix(EINVAL) }
         flow.serviceUpperReceiveQueue()
     }
+
+    // Enqueue and delivery the datagrams all in one shot
+    public func deliverInboundDatagrams(
+        flow flowID: MultiplexedFlowIdentifier,
+        datagrams: consuming FrameArray
+    ) throws(NetworkError) {
+        guard var flow = self.secondaryFlow(for: flowID) else { throw NetworkError.posix(EINVAL) }
+        try flow.addToUpperReceiveQueue(datagrams)
+        flow.serviceUpperReceiveQueue()
+    }
 }
 
 @_spi(ProtocolProvider)

Sources/SwiftNetwork/QUIC/QUICConnection.swift

@@ -5562,8 +5562,7 @@ extension QUICConnection {
 
         var frame = frame.frame
         frame.metadataComplete = true
-        try? enqueueInboundDatagrams(flow: matchingFlowIdentifier, datagrams: .init(frame: frame))
-        try? deliverEnqueuedInboundDatagrams(flow: matchingFlowIdentifier)
+        try? deliverInboundDatagrams(flow: matchingFlowIdentifier, datagrams: .init(frame: frame))
         return true
     }
 }

Tests/SwiftNetworkTests/TestMultiplexingProtocol.swift

@@ -91,8 +91,7 @@ final class TestMultiplexingProtocol: ManyToManyApplicationDatagramProtocol, Man
             return
         }
         accessReceivedDatagrams(path: path) { frames in
-            try? enqueueInboundDatagrams(flow: flow, datagrams: frames.drainArray())
-            try? deliverEnqueuedInboundDatagrams(flow: flow)
+            try? deliverInboundDatagrams(flow: flow, datagrams: frames.drainArray())
         }
     }