基于首元素谓词的可观性转换方法 [英] How to transform observable based on predicate involving first element

问题描述

我正在尝试创建一个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>()));

我更喜欢查询语法，但是...

这篇关于基于首元素谓词的可观性转换方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！