大佬教程收集整理的这篇文章主要介绍了WebSocket 异步发送和接收数据（使用 NuGet websocket-client），大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
public Task<Data> GetDataAsync()
{
var webSocket = new WebsocketClIEnt(Uri);
await webSocket.Start();
var requestID = GuID.NewGuID();
var tcs = new taskcompletionsource<Data>();
var disposable = webSocket
.messageReceived
.Where(message => message.Text.Contains(requestID))
.Subscribe(message=>
{
var data = ParseData(message.Text);
tcs.SetResult(data);
});
return tcs.Task;
}
public Task<Data> GetDataAsync(String request)
{
var requestId = Guid.NewGuid().ToString();
var responseTask = WebSocket
.messageReceived
.Timeout(TimeSpan.FromSeconds(5))
.FirstOrDefaultAsync(message => message.Text.Contains(requestId));
WebSocket.Send(request);
var responsemessage = await responseTask;
return Parsemessage(responsemessagE);
}
SingLeorDefaultAsync 而不是 FirstOrDefaultAsync 因为只有一条消息具有该请求 ID。但这不起作用。它总是在超时时间内运行。
,
@H_607_2@你让你的代码比我需要的要复杂得多。 Rx 让我们等待一个 observable 来获取最后产生的值。你可以这样写你的代码：
aria-label以上是大佬教程为你收集整理的WebSocket 异步发送和接收数据（使用 NuGet websocket-client）全部内容，希望文章能够帮你解决WebSocket 异步发送和接收数据（使用 NuGet websocket-client）所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。