我正在尝试编写一个典型的股票交易程序,它从 netmq 接收股票代码/订单/交易,将流转换为 IObservable,并在 WPF 前端显示它们。我尝试将 async/await 与 NetMQ 阻塞 ReceiveString 一起使用(假设我期待一些字符串输入),以便 ReceiveString 循环不会阻塞主(UI)线程。由于我还是 C# 的新手,因此我在这篇文章中接受了 Dave Sexton 的回答:( https://social.msdn.microsoft.com/Forums/en-US/b0cf96b0-d23e-4461-9d2b-ca989be678dc/where -is-iasyncenumerable-in-the-lastest-release?forum=rx)并尝试编写一些这样的示例:
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using NetMQ;
using NetMQ.Sockets;
using System.Reactive;
using System.Reactive.Linq;
namespace App1
{
class MainClass
{
// publisher for testing, should be an external data publisher in real environment
public static Thread StartPublisher(PublisherSocket s)
{
s.Bind("inproc://test");
var thr = new Thread(() => {
Console.WriteLine("Start publishing...");
while (true) {
Thread.Sleep(500);
s.Send("hello");
}
});
thr.Start();
return thr;
}
public static IObservable<string> Receive(SubscriberSocket s)
{
s.Connect("inproc://test");
s.Subscribe("");
return Observable.Create<string>(
async observer =>
{
while (true)
{
var result = await s.ReceiveString();
observer.OnNext(result);
}
});
}
public static void Main(string[] args)
{
var ctx = NetMQContext.Create();
var sub = ctx.CreateSubscriberSocket();
var pub = ctx.CreatePublisherSocket();
StartPublisher(pub);
Receive(sub).Subscribe(Console.WriteLine);
Console.ReadLine();
}
}
}
它无法使用“无法等待字符串”进行编译。虽然我知道它可能会期待一个任务,但我不太清楚如何完成整个事情。
再次包装:我想要实现的只是使用简单的阻塞 api 从 netmq 获取 IObservable 的ticker/orders/trades 流,但没有真正阻塞主线程。
我能用它做些什么吗?非常感谢。