Skip to content
Merged
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion NodeKit/NodeKit/Chains/ChainBuilder.swift
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@ 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) // Fixes a probable combine bug (Research in progress)
Comment thread
chausovSurfStudio marked this conversation as resolved.
Outdated
// Approximately 1-4% of requests go to finished before they receive a value
subscriber.receive(completion: .finished)
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

Expand Down