我有一个可观察的IObservable<T> / ISubject<T>，并希望使用SignalR返回它。SignalR有异步流的概念，您必须返回一个IAsyncEnumerable<T>。如何将IObservable<T>转换为IAsyncEnumerable<T>
浏览 14提问于2019-11-18得票数 5
回答已采纳
2回答
在使用IAsyncEnumerable<T>时，有可能节流数据吗？我有一个数据流快速进入，我只对最后一个元素感兴趣，每N秒。
谢谢。
浏览 6提问于2022-06-16得票数 0
2回答
source1发射A、B、C、D等，但从未完成我想合并到A1，B2，C1，D2等我最初的注意力是Zip和Repeat，这是来自Theodor的建议，但是这会创建一个锁，因为source2的生成非常昂贵。source1.Zip(source2.ToEnumerable().ToArray().Repeat())
浏览 9提问于2022-01-01得票数 2
回答已采纳
假设我有一个返回IObservable<T>的函数，这个函数需要初始状态。let resultObservable =
浏览 5提问于2020-06-22得票数 2
在这种情况下，对服务的方法调用返回一个IObservable<T1>，但是我们的客户端需要一个IObservable<T2>。将T1转换为T2非常简单。我知道我可以手动创建一个次要观察者，然后听取原始观察者的更改，并将其转发给新类型，但是我想知道是否有一种更干净的方法来实现它呢？
非常感谢，
浏览 1提问于2015-12-21得票数 3
回答已采纳
如何将可枚举xys的可观测性转换为可观测yxs的枚举，其中yxs的每个可观测到的集中在xys的每个时间步骤的特定元素上？我想要的类似于可枚举的可枚举项的换位。示例：{
Observable.G
浏览 4提问于2014-08-23得票数 3
回答已采纳
现在，我想使用一个返回IObservable<T>并产生多个对象的接口。我读到了关于.NET的Rx，这似乎是一条可行的道路。然而，我在犹豫是否要包含另一个依赖项和另一个新的范式，因为我已经在这个应用程序中使用了很多对我来说都很新的东西(比如XAML、MVVM、C#的async/await)。有没有类似于包装单个回调IObservable<T>的方法来包装API？我想这样调用API： foreach (var t in GetMultipleInstanc
浏览 8提问于2019-12-29得票数 1
我有一个IObservable<List<T>>，其中List<T>保证有一个元素。这里有什么SelectMany魔法吗？
浏览 2提问于2013-12-14得票数 1
回答已采纳
如何将可观察到的Timestamped<T>序列转换为TimeInterval<T>序列，其中间隔是原始序列上时间戳之间的时间？
浏览 1提问于2013-05-09得票数 4
回答已采纳
如何将IObservable<IObservable<Point>>转换成IObservable<IEnumerable<Point>>
浏览 4提问于2016-07-04得票数 3
回答已采纳
ToObservable扩展方法只会生成一个IObservable<Task<T>>，这不是我想要的，我想要一个IObservable<T>，然后我可以在上面使用Buffer。public static Task<int> makeInt() return Task.Run(() => 5);
//In practice, however, I don't//Mak
浏览 0提问于2013-06-12得票数 6
回答已采纳
我想知道是否有一种方法可以通过源对象创建IAsyncEnumerable<T>或IAsyncEnumerator<T>，就像TaskCompletionSource允许执行任务一样。特别是，可以像传递其他参数一样传递TaskCompletionSource。async Task<string> ParentMethod() {
浏览 7提问于2020-05-01得票数 4
在方法B的返回签名是IAsyncEnumerable的情况下，它是从MethodA内部调用的，是否可以返回IAsyncEnumerable，而无需迭代MethodB的返回值，如下所示：
IAsyncEnumerable<T> MethodA() => return MethodB(); <- this gives a com
浏览 0提问于2019-11-15得票数 1
2回答
因此，如果我正在为另一个库中的类型编写扩展方法，将该类型转换为Rx IObservable<T>，那么约定是什么呢？我不清楚什么时候或者是否有什么真正的约定。是否ToObservable被保留用于将期望生成单个事件的东西转换为IObservable<T>，其中AsObservable保留用于将预期生成一系列事件的东西转换为IObervable<T>
浏览 0提问于2013-08-16得票数 5
回答已采纳
有没有一种内置的方法可以将IEnumerable<Task>转换为IObservable。顺序并不重要，重要的是我得到了东西，尽管最好是在它们完成的时候。
如果它还不存在，什么可能是实现它的好方法？
浏览 0提问于2012-11-22得票数 9
回答已采纳
我正在使用DTO和MVVM，这意味着有时我需要将DTO之间的类型转换为ViewModels。在这个机会中，我不得不尝试将T转换为IObservable <T >。<StockModel> stockModel = null;
public IObservable<StockModel> Stock { get => stockModel;double Quantity { get => quantity; set
浏览 1提问于2019-12-04得票数 0
考虑一个方法DoSomething()，它返回：
不管是哪种方式，你的消费者都应该做他们喜欢做的事情，他们
浏览 6提问于2015-04-20得票数 0
回答已采纳
5回答
任务的协方差和逆方差
、、、、
鉴于下面的片段，我完全不明白为什么将实现什么是不可能的：public interface IEntityRepository<out T> : IRepository<IEntity> {void RequeryDataBase();
Task<IEnumerable<T>> SearchAsync在这一行中我得到了一个错误：Task<IEnumera
浏览 0提问于2016-07-01得票数 13
回答已采纳
我有一个返回IAsyncEnumerable的函数。我想await完成它，但我不关心任何结果。我只关心调用这个函数的副作用。我如何在不使用for循环或将其转换为容器(例如，await )的情况下轻松地完成IAsyncEnumerable？
浏览 3提问于2021-04-13得票数 0
回答已采纳
我的结果是IAsyncEnumerable<TItem>。但是，对于快速响应的UI来说，它应该是一个完美的数据类型--当我将它设置为网格的数据源时，它就不工作了，什么也没有显示。
我有两个解决办法。如果IAsyncEnumerable类型可以直接用作控件的数据源，这将是非常有意义的。但是，我可能需要实现某种IObservable接口或类似的东西。有人试过这个吗？我的意思是-如果您不能将它用于UI，那么IAsyncEnumerable有什么好处呢？更新:我想要的是IAsyncEnumer
浏览 8提问于2021-09-25得票数 3
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
