我的“zipLatest”操作符是否已经存在？

Question

关于我为自己写的一个操作员的快速问题。

请原谅我可怜的男人的大理石图：

zip
aa--bb--cc--dd--ee--ff--------gg
--11----22--33--------44--55----
================================
--a1----b2--c3--------d4--e5----

combineLatest
aa--bb--cc--dd--ee--ff--------gg
--11----22--33--------44--55----
================================
--a1b1--c2--d3--e3--f3f4--f5--g5

zipLatest
aa--bb--cc--dd--ee--ff--------gg
--11----22--33--------44--55----
================================
--a1----c2--d3--------f4------g5

zipLatest（我写的那个）与zip几乎同时触发，但没有排队zip包含。

我已经实现了它，我只是想知道它是否已经存在。我知道我以前写过一个类似的方法，偶然发现我在不知情的情况下编写了示例操作符。

那么，这是否已经存在于框架中，或者作为我没有想到的元素的一个微不足道的组成部分存在？

注意：我不想依赖输入的相等性来消除重复数据（a ladistinctUntilChanged）。它应该与仅在一个间隔上输出“a”的信号一起工作。

Answer 1

虽然您特别提到不要使用DistinctUntilChanged，但您可以将其与计数器一起使用，以获得不同的新值：

public static IObservable<(T, TSecond)> ZipLatest<T, TSecond>(this IObservable<T> source, IObservable<TSecond> second)
{
    return source.Select((value, id) => (value, id))
        .CombineLatest(second.Select((value, id) => (value, id)), ValueTuple.Create)
        .DistinctUntilChanged(x => (x.Item1.id, x.Item2.id), new AnyEqualityComparer<int, int>())
        .Select(x => (x.Item1.value, x.Item2.value));
}

public class AnyEqualityComparer<T1, T2> : IEqualityComparer<(T1 a, T2 b)>
{
    public bool Equals((T1 a, T2 b) x, (T1 a, T2 b) y) => Equals(x.a, y.a) || Equals(x.b, y.b);
    public int GetHashCode((T1 a, T2 b) obj) => throw new NotSupportedException();
}

请注意，我在这里使用了Int32，因为这是Select（）提供给我的，但对于某些用例来说，它可能太小了。Int64或Guid可能是更好的选择。

Answer 2

对这个问题进行更新：RxJS 6中仍然没有包含此要求的操作员，并且似乎没有计划在将来的版本中使用。也没有提出此运算符的打开拉取请求。

正如这里所建议的，组合使用组合测试、第一次和重复将产生预期的行为：

combineLatest(obs1, obs2).pipe(first()).pipe(repeat());

组合测试（CombineTest）将等待两个可见光的发射-丢弃除最新发射外的所有发射first将在发射后完成可观测值，并在CombineTest上重新订阅，使其再次等待两个可观测值的最新值。

重复的重新订阅行为没有完整记录，但可以在GitHub源代码中找到：

source.subscribe（this._unsubscribeAndRecycle（））；