标签:reactive-programming
-
发生异常时将IObservable <bool>和IObservable <Exception>合并到一个可观察到的OnErrors - c#
我正在尝试创建一个单一的Observable,它的OnNext流来自一个可观察的,哪个OnError流来自另一个可观察的。 之所以这样做,是因为我试图包装一个我控制范围之外的类,并使用事件来传达其状态。它有两个事件,一个指示完成(布尔),另一个指示发生异常。 IObservable<Exception> error = Observable.Fr […]
-
RxJava:使用基于Single的累加器进行的扫描,该扫描器处理中间的Single - java
我正在写一个基于Rx的单向UI流,其中每个状态的减少都是一个Single。通常,此类流程是使用scan完成的(它们需要先前的状态),但是当涉及到Single时,会有些棘手。我设法使它像这样工作: val events = Observable.just("event1", "event2", "event3& […]
-
RxJava-我什么时候应该取消订阅? - java
我想确保使用RxJava时不会造成任何内存泄漏。请让我知道这些是否是处理每种情况的正确方法。 案例1 如果我在同一范围内创建Observable和Subscription,GC会照顾好它们的处置吗?我必须在这里致电unsubscribe()吗? public static void createObservableAndSubscribe() { Obser […]
-
通过CompletableFuture并行执行一些线程,并串行执行一些线程 - java
我需要执行一些任务。有些任务是独立的,有些则依赖于其他任务的成功执行。可以并行运行独立任务以提高性能。我称这些任务为服务。link列告诉您哪些服务将串行执行,哪些将并行执行。 order列描述了一组定义的服务将遵循的执行顺序。对于下面的示例,服务A和B应该并行运行。如果它们已成功执行,则服务C将执行。请注意,服务C并不直接依赖于其先前服务的输出,而是必须在成 […]
-
有没有办法监听Reactive Extensions中没有引发的事件? - c#
我需要在用户开始键入时关闭某些功能,这很简单。当用户停止键入时,我想重新打开该功能。 如果没有反应性扩展,则可以使用timer简单地实现此功能,该功能可将每次最后一次击键时的计时器重置为1 second,并在user stops typing and timer elapses功能打开时将其重置。 有什么方法可以调用以实现与Reactive Extensio […]
-
SelectMany等待和结果排序 - c#
在Deep Dive into Rx SelectMany文章中,作者在最后的注释中提到了以下内容; 注意:为缓解订购问题,SelectMany()随附了一个 重载,它带有签名Func<TSource, int, Task<TResult>>的选择器。 有人可以启发我如何工作吗? c#大神给出的解决方案 在上述重载的元数据描述中,它表 […]