Question

我正试图了解如何利用追溯性延期来实施以下设想。我一直在研究的其他解决办法包括管理一系列时间,......我想尽可能避免。

Scenario
A stream of "ActionRequests" occurring. The ActionRequest s streaming in are from different object sources. I am only interested in picking off the most recent ActionRequest once requests have stopped coming in from a specific source for a period of x seconds

So breaking that down.

Events are being continuously received from different object sources.

The different object sources are denoted by a guid - see the ActionRequests class

After x number of seconds of silence from the object source the latest event is pushed out.

The older messages can be discarded once a more recent ActionRequest of interest has been received

public class ActionRequest
{
    public ActionRequest(Guid quoteId, DateTime now)
    {
        QuoteId = quoteId;
        RequestTimestamp = now;
    }

    public Guid QuoteId { get; set; }
    public DateTime RequestTimestamp { get; set; }

}

在这方面的任何想法都会受到赞赏。

Answer 1

答复载于,由Richard Hein提供。

答案的短文如下。在RX论坛的读物中添加了更完整的样本。

var throttled = observable.GroupBy(tar => tar.Value.QuoteId).SelectMany(g => g.Throttle(TimeSpan.FromMilliseconds(1500)));

友情链接