Databases
StackOverflow2013
Postsdbo
PODelay and de-duplication using Reactive Extensions (Rx)
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PODelay and de-duplication using Reactive Extensions (Rx)
    primarykey
    data
    text
    <p>I want to use Reactive Extensions to transform some messages and relay them after a small delay.</p> <p>The messages look something like this:</p> <pre><code>class InMsg { int GroupId { get; set; } int Delay { get; set; } string Content { get; set; } } </code></pre> <p>The output looks something like this:</p> <pre><code>class OutMsg { int GroupId { get; set; } string Content { get; set; } OutMsg(InMsg in) { GroupId = in.GroupId; Content = Transform(in.Content); // function omitted } } </code></pre> <p>There are a couple of requirements:</p> <ul> <li>The length of the delay is dependent on the content of the message. </li> <li>Each message has a GroupId</li> <li>If a newer message comes in with the same GroupId as a delayed message awaiting transmission then the first message should be dropped and only the second one transmitted after a new delay period.</li> </ul> <p>Given an Observable&lt;InMsg&gt; and a Send function:</p> <pre><code>IObservable&lt;InMsg&gt; inMsgs = ...; void Send(OutMsg o) { ... // publishes transformed messages } </code></pre> <p>I understand that I can use Select to perform the transformation.</p> <pre><code>void SetUp() { inMsgs.Select(i =&gt; new OutMsg(i)).Subscribe(Send); } </code></pre> <ul> <li>How can I apply a message specify delay? (Note this might/should result in out of order delivery of messages.)</li> <li>How can I de-dupe messages with the same GroupId?</li> <li>Is Rx capable of solving this problem?</li> <li>Is there another way of solving this?</li> </ul>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. This table or related slice is empty.
    1. USchillitom
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PO
      singulars
      1. PTAnswer
    1. VO
      singulars
      1. PODelay and de-duplication using Reactive Extensions (Rx)
      1. This table or related slice is empty.
      1. VTUpMod
    2. VO
      singulars
      1. PODelay and de-duplication using Reactive Extensions (Rx)
      1. This table or related slice is empty.
      1. VTUpMod
    3. VO
      singulars
      1. PODelay and de-duplication using Reactive Extensions (Rx)
      1. This table or related slice is empty.
      1. VTUpMod
    1. This table or related slice is empty.
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload