本文介绍了基于首元素谓词的可观性转换方法的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我正在尝试创建一个rx.net运算符,该运算符接受Observable<string>
和:
- 如果第一个元素
"a"
,则转发每个元素时保持不变 - 仅发出完成信号,否则
例如:
-a-b-c-d-|- --> -a-b-c-d-|-
-b-c-d-|- --> -|-
如何执行此操作?
推荐答案
以下版本完全没有竞争条件:
public static IObservable<T> IfFirstElement<T>(this IObservable<T> source, T expectedFirstElement) =>
source
.Publish(published =>
from x in published.Take(1)
from y in
x.Equals(expectedFirstElement)
? published.StartWith(x)
: Observable.Empty<T>()
select y);
有方法语法版本:
public static IObservable<T> IfFirstElement<T>(this IObservable<T> source, T expectedFirstElement) =>
source
.Publish(published =>
published
.Take(1)
.SelectMany(x =>
x.Equals(expectedFirstElement)
? published.StartWith(x)
: Observable.Empty<T>()));
我更喜欢查询语法,但是...
这篇关于基于首元素谓词的可观性转换方法的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!