StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

PO
text
Body
copied!<p>I promised to add the solution I came up with myself, so here it is. As long as I haven't found anything better I'll use this, although I still think there has to be a better way :)</p> <p>I use a class that uses a <code>ConcurrentDictionary</code> to keep the latest value from each registered observable. When an observable is unregistered, its latest value is removed again, as well as the subscription associated with it.</p> <p>When any registered observable generates a value, all latest values are collected and sent to a <code>Subject</code>.</p> <pre><code>public class DynamicCombineLatest<T> { private readonly IDictionary<IObservable<T>, T> _latestValues = new ConcurrentDictionary<IObservable<T>, T>(); private readonly IDictionary<IObservable<T>, IDisposable> _subscriptions = new ConcurrentDictionary<IObservable<T>, IDisposable>(); private readonly ISubject<IEnumerable<T>> _result = new Subject<IEnumerable<T>>(); public void AddObservable(IObservable<T> observable) { var subscription = observable.Subscribe(t => { _latestValues[observable] = t; _result.OnNext(_latestValues.Values); }); _subscriptions[observable] = subscription; } public void RemoveObservable(IObservable<T> observable) { _subscriptions[observable].Dispose(); _latestValues.Remove(observable); _subscriptions.Remove(observable); } public IObservable<IEnumerable<T>> Result { get { return _result; } } } </code></pre>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

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