Fix chain metadata override issue

NodeKit/NodeKit/Chains/ChainBuilder.swift

@@ -114,7 +114,7 @@ open class URLChainBuilder<Route: URLRouteProvider>: ChainConfigBuilder, ChainBu
     /// - Parameter root: The chain to which nodes will be added
     open func metadataConnectorChain<O>(
         root: any AsyncNode<TransportURLRequest, O>
-    ) -> some AsyncNode<Json, O> {
+    ) -> any AsyncNode<Json, O> {
         let urlRequestEncodingNode = URLJsonRequestEncodingNode(next: root)
         let urlRequestTrasformatorNode = URLRequestTrasformatorNode(next: urlRequestEncodingNode, method: method)
         let requestEncoderNode = RequestEncoderNode(next: urlRequestTrasformatorNode, encoding: encoding)

NodeKit/NodeKit/Core/Node/Combine/Subscription/AsyncNodeSubscription.swift

@@ -8,6 +8,7 @@
 
 /// Combine subscription for ``AsyncNode``.
 /// Contains base implementation, inheriting from `BaseSubscription`.
+/// - Warning: There is small delay between `subscriber.receive(_ input` and `subscriber.receive(completion:` to make sure that input will be published in publisher before completion.
 final class AsyncNodeSubscription<Node: AsyncNode, S: NodeSubscriber<Node>>:
     BaseSubscription<AsyncNodeResultPublisher<Node>, S> {
 
@@ -30,6 +31,7 @@ final class AsyncNodeSubscription<Node: AsyncNode, S: NodeSubscriber<Node>>:
         return Task {
             let result = await node.process(input, logContext: logContext)
             _ = subscriber.receive(result)
+            try? await Task.sleep(nanoseconds: 1_000_000)
             subscriber.receive(completion: .finished)
         }
     }

NodeKit/NodeKit/Layers/InputProcessingLayer/VoidIONode.swift

@@ -12,7 +12,7 @@ open class VoidIONode: AsyncNode {
 
     let next: any AsyncNode<Json, Json>
 
-    init(next: some AsyncNode<Json, Json>) {
+    public init(next: some AsyncNode<Json, Json>) {
         self.next = next
     }
 

NodeKit/NodeKit/Layers/InputProcessingLayer/VoidOutputNode.swift

@@ -12,7 +12,7 @@ open class VoidOutputNode<Input>: AsyncNode where Input: DTOEncodable, Input.DTO
 
     let next: any AsyncNode<Json, Json>
 
-    init(next: some AsyncNode<Json, Json>) {
+    public init(next: some AsyncNode<Json, Json>) {
         self.next = next
     }
 

NodeKit/NodeKit/Layers/ResponseProcessingLayer/ResponseDataParserNode.swift

@@ -41,7 +41,7 @@ open class ResponseDataParserNode: AsyncNode {
             await parse(with: data, logContext: logContext)
                 .asyncFlatMap { json, logMessage in
                     let logMsg = logMessage + .lineTabDeilimeter
-                    var log = LogChain(logMsg, id: objectName, logType: .info, order: LogOrder.responseDataParserNode)
+                    let log = LogChain(logMsg, id: objectName, logType: .info, order: LogOrder.responseDataParserNode)
 
                     guard let next = next else {
                         await logContext.add(log)