aboutsummaryrefslogtreecommitdiff
path: root/lib/Net.Messaging.FBM/src
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Net.Messaging.FBM/src')
-rw-r--r--lib/Net.Messaging.FBM/src/Client/FBMClient.cs4
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/Net.Messaging.FBM/src/Client/FBMClient.cs b/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
index 861811e..82b6c7e 100644
--- a/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
+++ b/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
@@ -140,11 +140,15 @@ namespace VNLib.Net.Messaging.FBM.Client
$"{REQ_RECV_BUF_QUERY_ARG}={Config.RecvBufferSize}" +
$"&{REQ_HEAD_BUF_QUERY_ARG}={Config.MaxHeaderBufferSize}" +
$"&{REQ_MAX_MESS_QUERY_ARG}={Config.MaxMessageSize}";
+
Debug("Connection string {con}", urib.Uri.ToString());
+
//Connect to server
await ClientSocket.ConnectAsync(urib.Uri, cancellationToken);
+
//Reset wait handle before return
ConnectionStatusHandle.Reset();
+
//Begin listeing for requets in a background task
_ = Task.Run(ProcessContinuousRecvAsync, cancellationToken);
}