library/simapi-net
1
0
Fork 0
Code Pull Requests Activity

Compare commits

base: library/simapi-net:8.3.1
Branches Tags
library/simapi-net:master
library/simapi-net:10.26.8.11 library/simapi-net:10.26.8.10 library/simapi-net:10.26.8.9 library/simapi-net:10.26.8.8 library/simapi-net:10.26.8.7 library/simapi-net:10.26.7.2 library/simapi-net:10.26.7.1 library/simapi-net:10.26.6.12 library/simapi-net:10.7.0 library/simapi-net:10.2606.10 library/simapi-net:10.26.6.11 library/simapi-net:10.26.06.11 library/simapi-net:10.06.10 library/simapi-net:10.6.9 library/simapi-net:10.6.8 library/simapi-net:10.6.7 library/simapi-net:10.6.6 library/simapi-net:10.6.5 library/simapi-net:10.6.3 library/simapi-net:10.6.2 library/simapi-net:10.6.1 library/simapi-net:10.6.0 library/simapi-net:10.5.2 library/simapi-net:10.5.1 library/simapi-net:10.5.0 library/simapi-net:10.4.0 library/simapi-net:10.3.5 library/simapi-net:10.3.4 library/simapi-net:10.3.3 library/simapi-net:10.3.2 library/simapi-net:10.3.1 library/simapi-net:10.3.0 library/simapi-net:10.2.1 library/simapi-net:10.2.0 library/simapi-net:10.1.8 library/simapi-net:10.1.7 library/simapi-net:10.1.6 library/simapi-net:10.1.5 library/simapi-net:10.1.4 library/simapi-net:10.1.3 library/simapi-net:10.1.2 library/simapi-net:10.1.1 library/simapi-net:10.1.0 library/simapi-net:10.0.4 library/simapi-net:10.0.3 library/simapi-net:10.0.2 library/simapi-net:10.0.1 library/simapi-net:10.0.0 library/simapi-net:9.1.4 library/simapi-net:9.1.3 library/simapi-net:9.1.2 library/simapi-net:9.1.1 library/simapi-net:9.1.0 library/simapi-net:9.0.8 library/simapi-net:9.0.7 library/simapi-net:9.0.6 library/simapi-net:9.0.5 library/simapi-net:9.0.4 library/simapi-net:9.0.3 library/simapi-net:9.0.2 library/simapi-net:9.0.1 library/simapi-net:9.0.0 library/simapi-net:8.4.7 library/simapi-net:8.4.6 library/simapi-net:8.4.5 library/simapi-net:8.4.4 library/simapi-net:8.4.3 library/simapi-net:8.4.2 library/simapi-net:8.4.1 library/simapi-net:8.4.0 library/simapi-net:8.3.5 library/simapi-net:8.3.4 library/simapi-net:8.3.3 library/simapi-net:8.3.2 library/simapi-net:8.3.1 library/simapi-net:8.3.0 library/simapi-net:8.2.9 library/simapi-net:8.2.8 library/simapi-net:8.2.7 library/simapi-net:8.2.6 library/simapi-net:8.2.5 library/simapi-net:8.2.4 library/simapi-net:8.2.3 library/simapi-net:8.2.2 library/simapi-net:8.2.1 library/simapi-net:8.2.0 library/simapi-net:8.1.9 library/simapi-net:8.1.8 library/simapi-net:8.1.7 library/simapi-net:8.1.6 library/simapi-net:8.1.5 library/simapi-net:8.1.4 library/simapi-net:8.1.3 library/simapi-net:8.1.2 library/simapi-net:8.1.1 library/simapi-net:8.1.0 library/simapi-net:8.0.9 library/simapi-net:8.0.8 library/simapi-net:8.0.7 library/simapi-net:8.0.6 library/simapi-net:8.0.5 library/simapi-net:8.0.4 library/simapi-net:8.0.3 library/simapi-net:8.0.2 library/simapi-net:8.0.1 library/simapi-net:8.0.0 library/simapi-net:7.0.9 library/simapi-net:7.0.8 library/simapi-net:7.0.7 library/simapi-net:7.0.6 library/simapi-net:7.0.5 library/simapi-net:7.0.4 library/simapi-net:7.0.3 library/simapi-net:7.0.2 library/simapi-net:6.1.7 library/simapi-net:6.1.6 library/simapi-net:6.1.5 library/simapi-net:6.1.4 library/simapi-net:6.1.3 library/simapi-net:6.1.2 library/simapi-net:6.1.1 library/simapi-net:6.1.0 library/simapi-net:6.0.9 library/simapi-net:6.0.8 library/simapi-net:6.0.7 library/simapi-net:6.0.6 library/simapi-net:6.0.5 library/simapi-net:6.0.4 library/simapi-net:6.0.3 library/simapi-net:6.0.2 library/simapi-net:6.0.1 library/simapi-net:6.0.0 library/simapi-net:5.7.3 library/simapi-net:5.7.2 library/simapi-net:5.7.1 library/simapi-net:5.7.0 library/simapi-net:5.6.8 library/simapi-net:5.6.3 library/simapi-net:5.6.2 library/simapi-net:5.6.1 library/simapi-net:5.6.0 library/simapi-net:5.5.5 library/simapi-net:5.5.1 library/simapi-net:5.5.0 library/simapi-net:5.4.1 library/simapi-net:5.4.0 library/simapi-net:5.3.4 library/simapi-net:5.3.3 library/simapi-net:5.3.2 library/simapi-net:5.3.1 library/simapi-net:5.3.0 library/simapi-net:5.2.3 library/simapi-net:5.2.2 library/simapi-net:5.2.1 library/simapi-net:5.2.0 library/simapi-net:5.1.1 library/simapi-net:5.1.0 library/simapi-net:5.0.6 library/simapi-net:5.0.5 library/simapi-net:5.0.4 library/simapi-net:5.0.3 library/simapi-net:5.0.2 library/simapi-net:5.0.1 library/simapi-net:5.0.0 library/simapi-net:1.1.3 library/simapi-net:1.1.2 library/simapi-net:1.1.1 library/simapi-net:1.1.0 library/simapi-net:1.0.5 library/simapi-net:1.0.3 library/simapi-net:1.0.2 library/simapi-net:1.0.1 library/simapi-net:1.0.0 library/simapi-net:0.5.1 library/simapi-net:0.5.0 library/simapi-net:0.4.5 library/simapi-net:0.4.2 library/simapi-net:0.4.1 library/simapi-net:0.4.0 library/simapi-net:0.3.6 library/simapi-net:0.3.5 library/simapi-net:0.3.4 library/simapi-net:0.3.3 library/simapi-net:0.3.2 library/simapi-net:0.3.1 library/simapi-net:0.3.0 library/simapi-net:0.2.10 library/simapi-net:0.2.9 library/simapi-net:0.2.8 library/simapi-net:0.2.7 library/simapi-net:0.2.6 library/simapi-net:0.2.5 library/simapi-net:0.2.4 library/simapi-net:v0.2.1 library/simapi-net:v0.1.3 library/simapi-net:v0.1.0
...
compare: library/simapi-net:8.3.2
Branches Tags
library/simapi-net:master
library/simapi-net:10.26.8.11 library/simapi-net:10.26.8.10 library/simapi-net:10.26.8.9 library/simapi-net:10.26.8.8 library/simapi-net:10.26.8.7 library/simapi-net:10.26.7.2 library/simapi-net:10.26.7.1 library/simapi-net:10.26.6.12 library/simapi-net:10.7.0 library/simapi-net:10.2606.10 library/simapi-net:10.26.6.11 library/simapi-net:10.26.06.11 library/simapi-net:10.06.10 library/simapi-net:10.6.9 library/simapi-net:10.6.8 library/simapi-net:10.6.7 library/simapi-net:10.6.6 library/simapi-net:10.6.5 library/simapi-net:10.6.3 library/simapi-net:10.6.2 library/simapi-net:10.6.1 library/simapi-net:10.6.0 library/simapi-net:10.5.2 library/simapi-net:10.5.1 library/simapi-net:10.5.0 library/simapi-net:10.4.0 library/simapi-net:10.3.5 library/simapi-net:10.3.4 library/simapi-net:10.3.3 library/simapi-net:10.3.2 library/simapi-net:10.3.1 library/simapi-net:10.3.0 library/simapi-net:10.2.1 library/simapi-net:10.2.0 library/simapi-net:10.1.8 library/simapi-net:10.1.7 library/simapi-net:10.1.6 library/simapi-net:10.1.5 library/simapi-net:10.1.4 library/simapi-net:10.1.3 library/simapi-net:10.1.2 library/simapi-net:10.1.1 library/simapi-net:10.1.0 library/simapi-net:10.0.4 library/simapi-net:10.0.3 library/simapi-net:10.0.2 library/simapi-net:10.0.1 library/simapi-net:10.0.0 library/simapi-net:9.1.4 library/simapi-net:9.1.3 library/simapi-net:9.1.2 library/simapi-net:9.1.1 library/simapi-net:9.1.0 library/simapi-net:9.0.8 library/simapi-net:9.0.7 library/simapi-net:9.0.6 library/simapi-net:9.0.5 library/simapi-net:9.0.4 library/simapi-net:9.0.3 library/simapi-net:9.0.2 library/simapi-net:9.0.1 library/simapi-net:9.0.0 library/simapi-net:8.4.7 library/simapi-net:8.4.6 library/simapi-net:8.4.5 library/simapi-net:8.4.4 library/simapi-net:8.4.3 library/simapi-net:8.4.2 library/simapi-net:8.4.1 library/simapi-net:8.4.0 library/simapi-net:8.3.5 library/simapi-net:8.3.4 library/simapi-net:8.3.3 library/simapi-net:8.3.2 library/simapi-net:8.3.1 library/simapi-net:8.3.0 library/simapi-net:8.2.9 library/simapi-net:8.2.8 library/simapi-net:8.2.7 library/simapi-net:8.2.6 library/simapi-net:8.2.5 library/simapi-net:8.2.4 library/simapi-net:8.2.3 library/simapi-net:8.2.2 library/simapi-net:8.2.1 library/simapi-net:8.2.0 library/simapi-net:8.1.9 library/simapi-net:8.1.8 library/simapi-net:8.1.7 library/simapi-net:8.1.6 library/simapi-net:8.1.5 library/simapi-net:8.1.4 library/simapi-net:8.1.3 library/simapi-net:8.1.2 library/simapi-net:8.1.1 library/simapi-net:8.1.0 library/simapi-net:8.0.9 library/simapi-net:8.0.8 library/simapi-net:8.0.7 library/simapi-net:8.0.6 library/simapi-net:8.0.5 library/simapi-net:8.0.4 library/simapi-net:8.0.3 library/simapi-net:8.0.2 library/simapi-net:8.0.1 library/simapi-net:8.0.0 library/simapi-net:7.0.9 library/simapi-net:7.0.8 library/simapi-net:7.0.7 library/simapi-net:7.0.6 library/simapi-net:7.0.5 library/simapi-net:7.0.4 library/simapi-net:7.0.3 library/simapi-net:7.0.2 library/simapi-net:6.1.7 library/simapi-net:6.1.6 library/simapi-net:6.1.5 library/simapi-net:6.1.4 library/simapi-net:6.1.3 library/simapi-net:6.1.2 library/simapi-net:6.1.1 library/simapi-net:6.1.0 library/simapi-net:6.0.9 library/simapi-net:6.0.8 library/simapi-net:6.0.7 library/simapi-net:6.0.6 library/simapi-net:6.0.5 library/simapi-net:6.0.4 library/simapi-net:6.0.3 library/simapi-net:6.0.2 library/simapi-net:6.0.1 library/simapi-net:6.0.0 library/simapi-net:5.7.3 library/simapi-net:5.7.2 library/simapi-net:5.7.1 library/simapi-net:5.7.0 library/simapi-net:5.6.8 library/simapi-net:5.6.3 library/simapi-net:5.6.2 library/simapi-net:5.6.1 library/simapi-net:5.6.0 library/simapi-net:5.5.5 library/simapi-net:5.5.1 library/simapi-net:5.5.0 library/simapi-net:5.4.1 library/simapi-net:5.4.0 library/simapi-net:5.3.4 library/simapi-net:5.3.3 library/simapi-net:5.3.2 library/simapi-net:5.3.1 library/simapi-net:5.3.0 library/simapi-net:5.2.3 library/simapi-net:5.2.2 library/simapi-net:5.2.1 library/simapi-net:5.2.0 library/simapi-net:5.1.1 library/simapi-net:5.1.0 library/simapi-net:5.0.6 library/simapi-net:5.0.5 library/simapi-net:5.0.4 library/simapi-net:5.0.3 library/simapi-net:5.0.2 library/simapi-net:5.0.1 library/simapi-net:5.0.0 library/simapi-net:1.1.3 library/simapi-net:1.1.2 library/simapi-net:1.1.1 library/simapi-net:1.1.0 library/simapi-net:1.0.5 library/simapi-net:1.0.3 library/simapi-net:1.0.2 library/simapi-net:1.0.1 library/simapi-net:1.0.0 library/simapi-net:0.5.1 library/simapi-net:0.5.0 library/simapi-net:0.4.5 library/simapi-net:0.4.2 library/simapi-net:0.4.1 library/simapi-net:0.4.0 library/simapi-net:0.3.6 library/simapi-net:0.3.5 library/simapi-net:0.3.4 library/simapi-net:0.3.3 library/simapi-net:0.3.2 library/simapi-net:0.3.1 library/simapi-net:0.3.0 library/simapi-net:0.2.10 library/simapi-net:0.2.9 library/simapi-net:0.2.8 library/simapi-net:0.2.7 library/simapi-net:0.2.6 library/simapi-net:0.2.5 library/simapi-net:0.2.4 library/simapi-net:v0.2.1 library/simapi-net:v0.1.3 library/simapi-net:v0.1.0
1 Commits
8.3.1 ... 8.3.2
Author SHA1 Message Date
xrain 6af68da3eb timeout rpc supported 2024-09-05 15:06:44 +08:00
2 changed files with 10 additions and 6 deletions
Expand all files Collapse all files
Synapse/RpcClient.cs
+4 -2
View File
@@ -40,7 +40,8 @@ public partial class Synapse
Client!.SubscribeAsync(rcSubOpts).Wait();
}
private string? FireRpc(string app, string action, object? param, Dictionary<string, string>? headers = null)
private string? FireRpc(string app, string action, object? param, Dictionary<string, string>? headers = null,
int? timeout = null)
{
string paramJson;
if (param is string strParam)
@@ -77,7 +78,8 @@ public partial class Synapse
string response;
try
{
if (tcs.Task.Wait(Options.RpcTimeout * 1000))
timeout ??= Options.RpcTimeout;
if (tcs.Task.Wait(timeout.Value * 1000))
{
response = tcs.Task.Result;
logger.LogDebug(
Synapse/Synapse.cs
+6 -4
View File
@@ -88,10 +88,11 @@ public partial class Synapse(SimApiOptions simApiOptions, ILogger<Synapse> logge
/// <param name="method"></param>
/// <param name="param"></param>
/// <param name="headers"></param>
/// <param name="timeout"></param>
/// <typeparam name="T"></typeparam>
/// <returns></returns>
public SimApiBaseResponse<T> Rpc<T>(string appName, string method, dynamic? param = null,
Dictionary<string, string>? headers = null)
Dictionary<string, string>? headers = null, int? timeout = null)
{
var res = new SimApiBaseResponse(500, "Synapse Rpc Client Disabled!");
if (Options.DisableRpcClient)
@@ -100,7 +101,7 @@ public partial class Synapse(SimApiOptions simApiOptions, ILogger<Synapse> logge
}
else
{
var data = FireRpc(appName, method, param, headers);
var data = FireRpc(appName, method, param, headers, timeout);
res = JsonSerializer.Deserialize<SimApiBaseResponse<T>>(data, SimApiUtil.JsonOption);
}
@@ -114,11 +115,12 @@ public partial class Synapse(SimApiOptions simApiOptions, ILogger<Synapse> logge
/// <param name="method"></param>
/// <param name="param"></param>
/// <param name="headers"></param>
/// <param name="timeout"></param>
/// <returns></returns>
public SimApiBaseResponse<object> Rpc(string appName, string method, dynamic? param = null,
Dictionary<string, string>? headers = null)
Dictionary<string, string>? headers = null, int? timeout = null)
{
return Rpc<object>(appName, method, param, headers);
return Rpc<object>(appName, method, param, headers, timeout);
}