Ich habe eine Folge von Ereignissen, die alle 10-1000 ms auftreten. Ich abonniere diese Ereignisquelle, möchte sie jedoch in einem festen (oder minimalen) Intervall von 500 ms behandeln. Ich möchte auch EIN Ereignis gleichzeitig verarbeiten, nicht stapelweise (wie Puffer (x> 1)).

So etwas in Pseudocode:

observable.MinimumInterval(TimeSpan.FromMiliseconds(500)).Subscribe(v=>...);

Versucht z.

observable.Buffer(1).Delay(TimeSpan.FromMiliseconds(500).Subscribe(v=>...);

und viele andere mögliche Lösungen. Bisher kein Glück.

Irgendwelche Ideen?