如果x毫秒前发生相同的发射，则阻止发射

Question

当且仅当相同的项目在最后x毫秒内发射时，我想防止发射发生。我已经查看了油门和防抖操作符，但我不确定它们是否可以在这里帮助我。我可以使用其他操作符吗，或者我可以以某种方式组合它们吗？

Answer 1

因为您的问题没有完全解释像比较下一个发射值与最后一个发射值或任何最后一个发射值或其他情况这样的场景。我会采取一种通用的方法来解决这个问题。

示例在RxJava中。

可以将timestamp（）与filter（）操作符一起使用，如下所示：

ArrayList<String> list = new ArrayList<>();
        final long[] timeOfSubscribe = {-1};
        final long timeDuration = 2 * 1000; // 2 seconds
        Observable.fromIterable(list)
                .timestamp()
                .filter(item -> item.time() > (timeDuration + timeOfSubscribe[0]) && item.value().equals("your last value"))
                .doOnSubscribe(__ -> timeOfSubscribe[0] = Calendar.getInstance().getTimeInMillis())
                .subscribe();

我想这段代码可以帮助您只需更改位于filter（）操作符中的发出值比较登录名。如果您正在查找上次发出的值，可以使用操作符停止上次发出的值（以便于使用简单的大小写），或者如果您正在查找所有上次发出的值，则需要将发出的值存储在列表中并进行检查。

我希望这有帮助。

Answer 2

您可以为每个项目添加时间戳并配对，然后检查时间和相等的边界条件。

   randomSource
                .timestamp()
                .pairwise()
                .where(pair => pair[0].timestamp - pair[1].timestamp < limit && pair[0].value === pair[1].value);

然后应用<代码>。选择（配对=

C#中的工作示例，其源在随机时间间隔内生成1到5个随机项目：

    static IObservable<T[]> Pairwise<T>(this IObservable<T> source)
    {
        source = source.Publish().RefCount();
        return source.Skip(1).Zip(source, (a, b) => new[] { a, b });
    }

    static void Main(string[] args)
    {

        var randomSource =
            Observable.Defer(() => Observable.Timer(TimeSpan.FromSeconds(new Random().NextDouble() * 2))).Repeat().Publish().RefCount().Select(_ => new Random().Next(1, 5));

        var limit = TimeSpan.FromSeconds(1);

        var sameDebounce =
        randomSource
            .Timestamp()
            .Pairwise()
            .Where(pair => pair[0].Timestamp - pair[1].Timestamp < limit && pair[0].Value == pair[1].Value);


        sameDebounce.Subscribe(c => Console.WriteLine("{0} {1}", c[0], c[1]));
        Console.ReadLine();

    }

输出：

2@9/7/2017 5:00:04 AM +00:00 2@9/7/2017 5:00:04 AM +00:00
2@9/7/2017 5:00:09 AM +00:00 2@9/7/2017 5:00:08 AM +00:00
1@9/7/2017 5:00:23 AM +00:00 1@9/7/2017 5:00:23 AM +00:00
2@9/7/2017 5:00:33 AM +00:00 2@9/7/2017 5:00:32 AM +00:00

Answer 3

您可以使用groupByUntil来实现这一点，从而从本质上消除单个项目的影响

o
  .groupByUntil(x => x, x => x, x => Observable.timer(1000))
  .flatMap(grp => grp.first())