反应式扩展Observerable.FromAsync:如何等待直到异步操作完成

文章/答案/技术大牛

发布

2回答

c#、system.reactive

为了实现这一点，我使用Rx来序列化事件并异步执行处理，这样就不会阻塞生产者。问:在处理订阅之后，等待最后一个事件处理的最佳方式是什么？我还在试着用async Rx的东西来包装我的大脑。我想有一种相当简单的方法可以做到这一点，只是我现在还没有看到。

浏览 38提问于2020-06-16得票数 1

回答已采纳

1回答

Rx:拼接多个IObservable web请求

c#、asynchronous、webrequest、system.reactive

我正在使用IObservables和反应式扩展创建多个异步web请求。我也能做到使用IObservables和LINQ执行多个异步web请求的正确方式是什么，这些请求必须等待其他请求完成？还有一个额外的问题，在这种情况下，我想同时执行web调用，当所有调用都完成时，执行另一个观察值，直到其他调用<e

浏览 1提问于2010-04-06得票数 3

回答已采纳

2回答

使反应式扩展缓冲等待异步操作完成

c#、.net、task-parallel-library、system.reactive

我正在使用反应式扩展(Rx)来缓冲一些数据。我有一个问题，因为我需要对这些数据做一些异步操作，但我不希望缓冲区在异步操作完成之前传递下一组数据。();{} 不幸的是，这两种方法都不起作用，因为在异步操作完成之前这样做的目的是让每个缓冲组

浏览 0提问于2013-06-13得票数 6

回答已采纳

2回答

如何等待一个可观察对象完成？

.net、f#、reactive-programming、system.reactive

我想知道是否有可能使用反应式扩展来做这样的事情？我知道如何设置命名管道，并在另一个进程中利用它与Node服务器通信，但我不确定如何防止程序通过等待按键以外的任何方式终止。我希望将该服务器作为反应式管道的一部分来实现。是否可以阻塞主线程，直到管道完成？

浏览 11提问于2020-05-10得票数 2

回答已采纳

2回答

在reactive中有像ThrottleWhile或SubscribeAsync这样的东西吗？

reactive-programming、system.reactive、unirx

我有一个异步订阅逻辑，当它运行时，我不希望它再次运行，直到该逻辑完成。但是，如果在运行逻辑时观察到任何事件，它将被限制，直到订阅逻辑完成，然后立即再次触发observable.SubscribeAsync(async(data) => await DoSomething我希望限制输入数据，而不是跳过或等待，而是限制它。所以我认为如果我们有ThrottleWhile (也许还有DebounceWhile或ThrottleUntil)可能会更好。我如何</

浏览 4提问于2020-08-07得票数 1

1回答

通过每次读取几次不确定的写入来提升Beast WebSockets

c++、boost、websocket、beast

相反，您一直向它发送音频数据，直到它识别出停顿或讲话结束，然后它最终返回一些结果。换句话说，在读取返回任何内容之前，您可能必须执行几次写入操作，并且无法预测需要执行多少次写入操作。如果没有非阻塞读函数，并且没有将阻塞读放在单独的线程中，我如何继续发送数据，然后只在结果可用时检索结果？

浏览 5提问于2018-05-06得票数 2

2回答

调度程序、异步/等待、并发工作

c#、multithreading、parallel-processing、async-await、dispatcher

我有一堆异步方法，我从Dispatcher调用它们。这些方法不会在后台执行任何工作，它们只是等待一些I/O操作，或者等待wait服务器的响应。我的第一次尝试是使用Paralell.Foreach()，但id在异步/等待模式下不能很好地工作。{MaxDegreeOfParallelism = 10};我一直在寻找反应式<

浏览 9提问于2016-07-22得票数 0

回答已采纳

1回答

如何等待异步/等待进程，直到得到结果？

react-native、async-await

我有一个异步/等待进程，如下所示 async function getFirebaseToken() {} 由于这是一个异步操作，我们不能说这个过程何时完成。关于如何等待异步/等待进程直到得到结果，有什么建议吗？

浏览 10提问于2020-08-06得票数 0

回答已采纳

1回答

异步加载树层次结构

c#、system.reactive

我考虑支持树中所有节点的异步加载，但我不确定这是否是一个好主意。我正计划为此使用反应性扩展。1| |- 1.1.1|-- 1.2 |- 1.2.2 节点1异步加载1.1和1.2并等待它们完成，然后依次加载1.1.1、1.1.2、1.2.1、1.2.2.这就是6次异步加

浏览 0提问于2018-11-03得票数 1

回答已采纳

2回答

这是异步等待工作的正确图表吗？

c#、.net、multithreading、asynchronous、async-await

我试图以这些段落为基础 “等待”关键字是东西可以异步的地方。等待就像一个一元操作符:它接受单个参数，awaitable (“awaitable”是异步操作)。等待检查awaitable，看看它是否已经完成；如果awaitable已经完成，那么该方法只是继续运行(同步，就像一个常

浏览 0提问于2016-12-11得票数 5

1回答

等待什么时候检查一下？

c#、.net、multithreading、asynchronous

await Task.Delay(100);“等待”关键字是东西可以异步的地方。等待就像一个一元操作符:它接受单个参数，awaitable (“awaitable”是异步操作)。等待检查awaitable，看看它是否已经完成；如果awaitable已经完成，那么该方法只是

浏览 2提问于2017-10-25得票数 0

3回答

异步安全地读取文件中的所有行

c#、io、.net-3.5

我试图异步、安全地从文件中读取(所寻求的最低权限级别)。我使用的是.NET 3.5，因此找不到一个很好的例子(所有这些都使用异步和等待)。allText, 0, (int) allText.Length); return encoding.GetString(allText);问题是，如何在.net 3.5中异步完成此操作，直到操作完成并将所有行发送给调用方？调用

浏览 4提问于2013-09-13得票数 2

回答已采纳

1回答

在同步方法上等待/异步，什么是“异步过程”？什么时候“控制权返回给调用者”？嵌套等待

c#、multithreading、asynchronous、async-await

Task.Run, no pun intended)我认为会发生的事情：这里的关键是什么代表异步操作。因为考虑到

浏览 2提问于2022-06-08得票数 -1

回答已采纳

1回答

在Dart语言中异步/等待的确切而明确的含义是什么？

dart、asynchronous、async-await

我理解使用Future.在Dart中使用异步编程的概念。通过这样做，我们尝试在后台异步完成一些事情，而不是停止应用程序。注意:尽管异步函数可能执行耗时的操作，但它不会<e

浏览 5提问于2022-07-04得票数 0

2回答

动画按钮阻止排毒

detox

它跟踪几个异步操作并等待它们完成。这包括：很明显，有一条线说要跟踪挂起的动画，所以如果按钮继续这样的话。那它还会继续

浏览 1提问于2017-11-20得票数 8

2回答

在使用“等待”时读取文本文件和代码

c#、asynchronous、async-await、windows-8.1

masterDataObject = customerFromJSON;}我相信等待意味着执行将停止，直到从调用的代码得到响应(显然不是)。那么，我应该如何使用异步来使它正常工作，或者有比这段代码更好的替代方案呢？我已经看过并尝试了许多选择，但没有成功，任何

浏览 2提问于2015-03-23得票数 2

回答已采纳

1回答

在异步i/o操作符等待响应时，flink检查点停止。

asynchronous、async-await、apache-flink、flink-streaming

异步i/o操作符(1.15.2)正在等待未来的返回(基本上让嵌入式函数完成其处理)，直到检查点在这个操作符处停止。只有当它完成后才能继续。附上截图。基本上，我想测试异步io正在等待响应的场景&作业被重新启动。因此，理想情况下，最后一个检查点将被恢复&从技术上讲，异步i/o处理应该使用相同的数据集重新启动。请指导我应该如何处理这种情况。

浏览 18提问于2022-11-18得票数 1

2回答

以反应式方式处理事务性资源

transactions、akka、distributed、reactive-programming

我即将在金融领域开始一个新项目，其中全局和分布式事务目前统治着世界，但是在反应式世界中，事情在不同的线程中完成，并且actors异步执行，经典的方法将不起作用。下面是一个例子。在反应式世界中如何处理事务性数据源？我正在寻找STM，似乎它解决了问题，唯一的事情是我必须显式地处理异常(通过akka中的监督)和回滚事务。然而，我可以看到违反反应式的做事方式，MQ消费者参与者必须等待(阻止？！)直到从另一个参与者(业务逻辑或其他事务性数据源)收到异常或成功确认

浏览 2提问于2015-10-01得票数 3

1回答

主线程没有等待订阅者在reactive subscriber中完成其任务

java、spring、multithreading、spring-webflux、project-reactor

我想让这些方法并行执行一些DB操作，然后返回到父线程。但是父线程应该等待，直到所有的响应到来，然后返回一个响应。在我目前的方法中，我使用反应式mono异步执行所有方法，但主线程并不等待subscriber方法完成。return response;Inside getProfileDetails Inside getAddressDetails 我的输出显示主线程没有等待订阅服务器完成它

浏览 13提问于2020-01-09得票数 1

回答已采纳

2回答

Javascript对C#的异步/等待

javascript、c#、asynchronous、async-await

我试图理解异步编程，并遇到异步/等待关键字。我无法理解异步/等待关键字的使用。我实际上查看了两种编程语言，JavaScript和C#，发现在这两种语言中异步/等待关键字的使用有很大不同。对于JavaScript，它说：异步/等待使您的代码看起来是同步的，并且在某种程度上它使代码的行为更加同步。“等待”关键字将阻止后续所有代码的执行，直到承诺实现为止，与同步

浏览 14提问于2021-05-20得票数 6

回答已采纳

点击加载更多