本文介绍了基于首元素谓词的可观性转换方法的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我正在尝试创建一个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>()));
我更喜欢查询语法，但是...
这篇关于基于首元素谓词的可观性转换方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！