订阅IObservable<T>而不是类型委托

文章/答案/技术大牛

发布

1回答

c#、excel、vb.net

然而，我只有一个例子告诉我如何订阅这个服务是在vba中，我不知道它是如何附加到它的。Create(Type loggerType) => new TypedLogger(loggerType, _outputStream.Value); End If End Sub) 我在转换它时得到了一些帮助，我的lambda表达式一直有问题，因为它不是我理解的委托</em

浏览 6提问于2020-12-14得票数 0

回答已采纳

1回答

在WebClient.DownloadProgressChanged中使用Observable.FromEvent

system.reactive

我正在尝试使用反应式扩展(Rx)来订阅WebClient.DownloadProgressChanged。据我所知，因为DownloadProgressChanged使用了自定义委托类型，所以我需要使用冗长的FromEvent重载： h => client.DownloadPro

浏览 0提问于2011-01-30得票数 0

回答已采纳

3回答

如何对这种泛型扩展方法进行Resharper结构搜索？

c#、resharper、system.reactive

有谁能指导我如何为下列签名创建一个重发器结构搜索：{}我尝试了几个选项，但似乎无法使其与此泛型类型

浏览 2提问于2014-03-07得票数 0

回答已采纳

6回答

在IDisposable接口中返回一个IObservable<T>的目的是什么？

c#、design-patterns、system.reactive、observer-pattern、idisposable

如果在尝试订阅时查看IObserver，则该方法将返回一个IDisposable。为什么有必要这么做？为什么不直接实现一个基于方法参数不对IObserver进行描述的方法呢？。这使观察者能够在提供者发送完通知并调用订阅者的OnCompleted方法之前取消订阅(即停止接收通知)。

浏览 0提问于2012-05-16得票数 16

回答已采纳

2回答

我一直在尝试创建一个基本的观察者模式，它使用泛型类型在可观察对象和它的订阅者之间创建一个紧密耦合的关系。例如，YouTube；通道将是可观察的对象，订阅者将是YouTube用户。YouTube信道只能由YouTube用户订阅，而YouTube用户只能订阅通道。因此，例如，您不能使用YouTube帐户订阅报纸或果冻俱乐部。<T> : ISubscriber where T : IObservable 这是可

浏览 2提问于2017-03-22得票数 0

回答已采纳

1回答

如何实现IObservable

c#、.net-core、observable、system.reactive

class Producer:IObservable<int> private object @lock = new object(); { public IObservableSubscribe(IObserver<int> ob

浏览 18提问于2018-12-30得票数 2

回答已采纳

2回答

Rx.NET "gate“操作符

c#、system.reactive

public static IObservable<T> When<T>(this IObservable<T> source, IObservable<bool> gate) var sSubscribe(value => flag = value); } 除了总体的冗长之外，我不喜欢我订阅</e

浏览 49提问于2018-06-03得票数 2

2回答

如何实现从一个IObserver到另一个an的原子切换？

c#、.net、system.reactive

我有一个IObservable<byte[]>，我使用一些中间步骤将其转换为IObservable<XDocument>： from b inintermediate steps to transform byte arrays into XDocuments在某些时候，我对观察到的XDocument感兴趣，所以我订阅了一个在以后的某个时间点，我想订阅另一个IObserver<XDocument>

浏览 2提问于2011-06-14得票数 3

回答已采纳

2回答

对类型化消息代理使用Rx

.net、system.reactive

我有一个类型化的消息代理，与Caliburn提供的类似：{ IDisposableSubscribe<T>(Action<T> subscriber);如何将订阅转换为IObservable？我想要一个扩展方法，就像这样： public static IObservable&

浏览 0提问于2010-10-04得票数 0

回答已采纳

1回答

Rx .Net触发基于objects datetime属性的操作(即日期从未来传递到过去)

c#、system.reactive

我对反应世界相当陌生，所以请原谅我的无知。因此，对于一个示例对象： { }

浏览 0提问于2019-07-17得票数 0

回答已采纳

2回答

我是否应该使用List<IObserver>或简单的Action<T>来跟踪I观测者的订阅者？

c#、.net、delegates、system.reactive

我正在一些类上实现IObservable<T>接口。我使用来了解这在中通常是如何完成的。关于一个可观察到的用户如何跟踪它的订阅者并通过他们的OnNext方法通知他们，我偶然发现了类似于以下代码的代码：public IDisposable Subscribe(IObserver<T> observer)

浏览 3提问于2010-10-23得票数 4

回答已采纳

4回答

什么时候使用IEnumerable与IObservable？

c#、.net、ienumerable、system.reactive

如何确定方法应返回IEnumerable<T>还是IObservable<T> 为什么我要选择一个范式而不是另一个呢？

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

回答已采纳

2回答

侦听列表中项目内部的可观察事件

c#、system.reactive

我有一个IObservable<ImmutableArray<T>>，其中每个T都有一个相应的Delete命令，一个IObservable<Unit>。当用户单击列表中的某个项目时，我会尝试作出响应。如果项目X被添加到列表中，并且列表多次更改，我希望确保我只在X上订阅了一次删除命令-当它被添加时-而不是每次列表更改时取消订阅和重新订阅。最初，我尝试使用Switch命令来完成此操作。我想我遇到了其他

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

1回答

观察者<T>..OnError的假设似乎与Stubs.Throw不一致

system.reactive

IObservable.Subscribe上的重载之一是在内部，这将在AnoymousObserver<T>上创建和注册一个IObservable。在内部，IObservable的观察者都包含在一个类型为观察者的实例中

浏览 0提问于2013-01-21得票数 1

回答已采纳

2回答

以通用方式在运行时将事件处理程序分配给对象实例

.net、events、event-handling、generics

logic } 目前，我传入了一个assignEvent和deassignEvent委托

浏览 0提问于2011-03-05得票数 2

回答已采纳

1回答

如何从IObservable订阅但缓冲数据，直到另一个IObservable发布为止？

c#-4.0、system.reactive

我想：订阅是第一件发生的事情，这是非常重要的。s2:IObservable<bool> t r

浏览 5提问于2011-09-20得票数 2

回答已采纳

1回答

通过主题首选的方法来装饰IObservable？

c#、system.reactive

我一直在创建一系列特定于域的IObservable扩展方法，但基本上都是通过另一个类(实现ISubject)传递现有序列的形式，并提供了净输出。<T> Decorate<T>(this IObservable<T> input, Func<ISubject<T>> subjectFactory) return Observable.Create我正在寻找一个ISubject<T

浏览 1提问于2014-12-05得票数 0

1回答

反应性扩展中的数据服务

c#、system.reactive

基础模型从具有字符串类型Id的接口继承。{}我的问题是：您将如何处理删除而不引入另一个类来包装我的模型？我想保留一个IObservable<TModel>，而不是像IObservable<Event<TModel>>或IOb

浏览 1提问于2015-06-12得票数 3

回答已采纳

1回答

区分因错误和完成而被处理的可观察到的

c#、system.reactive

我有一个订阅，如下所示：{ .OnDispose(() => Console.Writeline("disposed")}public static IObservable<T> OnDispose<T>(

浏览 14提问于2022-11-10得票数 0

回答已采纳

2回答

IObservable REST客户端

c#、.net、rest、client-side、system.reactive

我想我有几个选择： 1)暴露IObservable<IEnumerable<T>>。有道理，REST服务一次返回所有请求的数据。2)暴露IObservable<T>。我想在某些情况下可能是个不错的选择。Subscribe()只能调用一次，要获取其他数据，需要使用Refresh()或NextPage() (...)方法。(然后，它可以是一个属性IObservable<T> Resource { get; }，而不是<

浏览 0提问于2012-08-14得票数 3

回答已采纳

点击加载更多