Paired
with current
and previous
fields is kinda weird.
Pairwise() : Observable<Pairwised<T>>
Pair<T>
is not ideal as a public type with fields Current
and Previous
Pairwised
doesn't improve that.
Observable<Timestamp<T>> timestamp(this Observable<T> source, IScheduler scheduler)
in C#
See
Replay<TSource>(IObservable<TSource>, Int32)
Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Another interesting you could sometimes use is
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32)
Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
You call it with source.Replay((src) => { ... }, 1)
(src) => { ... }
here is the selector function and inside there nyouy can use src
as many times as you want and it will replay the latest value each time you subscribe to it, but after Replay you have a normal Observable
instead of ConnectableObservable
that you need to connect to etc.
For example source.Replay(src => src.concat(src))
will emit source like normal, but replay the last value on complete
.
What is the status of reactive programming in c#/.net?
All these things combined makes my customers confused about the status of reactive programming in .NET and unless I find and point them to clear, concise and unambiguous resources which ensures that Microsoft is behind the technology, actively developing and supporting it and that is has a road-map where it show that it is a core part of the .NET Framework for many versions to come.
They were burned by Microsoft abandoning both Silverlight and LightSwitch.
Hi. I have problem with error handling within R. I'm using SourceCache in .net. And I'm using.Subscribe(()=> throw new Exception, e=> Log.Error(e))
I would suspect lambda passed to onError will trigger, its not triggering.
At this moment I'm getting Unhandled exception and application crash.
I need a way to not crash the system when exception in subscribe happening.
Does anyone have any clue why it's behaving like this or how can I catch this exception?
.Select(()=> throw new Exception())
.Subscribe(() => {}, e=> Log.Error(e));