Questions tagged [system.reactive]
System.Reactive refers to the Reactive Extensions for .NET, also known as Rx, but it more specifically refers to the use of the System.Reactive.dll assembly, which is part of Rx. System.Reactive provides developers with a reactive programming model, as opposed to the traditional imperative programming model.
36 questions
2
votes
0
answers
2k
views
High-performance ClientWebSocket wrapper
I'm working on a web socket client wrapper around ClientWebSocket and this is kinda my first public library project, which is why I'm asking this question here. I ...
- 819
4
votes
0
answers
188
views
Create IObservable<T> From Func<T>
These extensions create an IObservable<T> that creates a long running task that can be cancelled. It runs the Func<T>...
2
votes
0
answers
83
views
Reactive .NET retry policy
I haven't found a good code example for a reactive retry operator with a retry strategy that was good enough for my needs. So I tried to make my own. It seems to work in my tests but I would really ...
- 21
7
votes
1
answer
13k
views
Async selector in LINQ
LINQ Select usually works like this:
IEnumerable<Task<int>> res = new[] {1,2,3}.Select(async i => i);
I would ...
- 6,131
6
votes
0
answers
427
views
Display Child View and Subscribe to its event on ReactiveUI
I am very confuse what is better approach to display child view and subscribe to its event on ReactiveUI WPF, so far I have 2 implementation that somehow works for my case:
Implementation 1:
...
- 116
3
votes
0
answers
1k
views
Reactive Extensions wrapper around Confluent.Kafka for .NET
Just an Rx wrapper around Kafka to represent topic consumption as IObservable<T>:
...
- 173
1
vote
1
answer
196
views
Using Reactive Extensions in an Asynchronious Way
I am new to Reactive Extensions, I have the requirement to consume PairCollection<IPointCloud> which are fed into a service which performs a very expensive ...
- 829
4
votes
2
answers
144
views
Reactive operator for distinct values that must change by amount
I would like feedback on this DistinctUntilChangedBy operator for System.Reactive that only emits when the current value is ...
- 141
5
votes
1
answer
213
views
Rx.NET operator
I need an operator to allow a stream of booleans to act as a gate for another stream (let values pass when the gate stream is true, drop them when it's false). I would normally use Switch for this, ...
- 161
4
votes
0
answers
102
views
Mechanism for providing timeout notifications when traffic ceases
I'm trying to build a nicely encapsulated mechanism for providing timeouts that wait for a signalling channel to go quiet for a duration. As a fun study of ...
- 161
4
votes
1
answer
1k
views
Observable Logger
I'm experimenting with an alternative abstraction layer for logging that is build on top of the Reactive Extensions. This allows me to easily add features I need to my layer and map logs to any other ...
- 44.7k
10
votes
2
answers
2k
views
Retry and CircutBreaker the reactive way
I wrote a simple utility for Retry and CircuitBreaker patterns. I implemented it by using ReactiveX because I thought it might actually be the perfect framework for it. I know that there is a project ...
- 44.7k
4
votes
2
answers
2k
views
Generic parallel task queue returning an observable sequence of return value
This is a continuation of Parallel Task Queue that runs in sequence.
Using Reactive Extensions I want to create a generic class a that process a task and executes it on a specific queue returning a <...
- 151
0
votes
1
answer
503
views
Merging union Observables
I am having a scenario where I need to execute observables that depends on the result of the first one. However I need to keep the result of the first observable. I couldn't find any extension that ...
- 5,606
2
votes
2
answers
2k
views
