本文介绍了基于首元素谓词的可观性转换方法的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

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

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

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

10-24 17:01