Skip to content

Commit 411b3c6

Browse files
committed
chore: rebased onto staging for esm
1 parent a031648 commit 411b3c6

File tree

3 files changed

+3
-4
lines changed

3 files changed

+3
-4
lines changed

src/nodes/NodeConnection.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -298,9 +298,7 @@ class NodeConnection {
298298
const rpcClient = new RPCClient<AgentClientManifest>({
299299
manifest,
300300
middlewareFactory: rpcUtilsMiddleware.defaultClientMiddlewareWrapper(),
301-
streamFactory: async () => {
302-
return quicConnection.newStream();
303-
},
301+
streamFactory: async () => quicConnection.newStream(),
304302
toError: networkUtils.toError,
305303
logger: logger.getChild(RPCClient.name),
306304
});

src/nodes/NodeConnectionManager.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,6 +1047,7 @@ class NodeConnectionManager {
10471047

10481048
// Creating TTL timeout.
10491049
// Add to map
1050+
// TODO: update type to something like ConnectionDetails
10501051
const newConnAndTimer: ConnectionAndTimer = {
10511052
connection: nodeConnection,
10521053
timer: null,

src/nodes/agent/handlers/NodesAuthenticateConnection.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ class NodesAuthenticateConnection extends UnaryHandler<
2020
> {
2121
public handle = async (
2222
input: AgentRPCRequestParams<NodesAuthenticateConnectionMessage>,
23-
_cancel,
23+
_cancel: (reason?: any) => void,
2424
meta: Record<string, JSONValue> | undefined,
2525
ctx: ContextTimed,
2626
): Promise<AgentRPCResponseResult<SuccessMessage>> => {

0 commit comments

Comments
 (0)