All Questions
80
questions
0
votes
0
answers
22
views
ReactiveUI ViewModel Unit Testing how to test that a Invoke comes from a certain WhenAnyValue
I am trying to write a unit test that tests my ReactiveUI ViewModel. In my ViewModel I want to retrieve comments from my database. You can also filter these comments by text and by creator.
For ...
- 11
0
votes
1
answer
89
views
Observable from Func delegate
Is there a method or library function that would accept Func<T> and return IObservable<T> by invoking it?
The functionality should be probably equal to
public IObservable<T> Create&...
- 79
2
votes
2
answers
127
views
How to pull from IObservable
Suppose there is a Subject<T> at endpoint A and an IObservable<T> on endpoint B.
Endpoint A sends exactly one object of T using OnNext() and never calls OnComplete(). I don't have a ...
- 197
0
votes
0
answers
40
views
How can I bind command from MainViewModel to my Menu.ItemTemplate
Now I have this axaml:
`<Menu
Background="#1A1E27"
<MenuItem
Header="Open"
ItemsSource="{Binding Projects}"
>
<MenuItem.ItemTemplate>
&...
0
votes
1
answer
177
views
What is the way of creating custom Reactive attribute?
I work with Reactive UI library for my WPF applications and was curious about how does the [Reactive] attribute work. I found out that there is nothing there in the attribute itself so there was a lot ...
- 720
2
votes
1
answer
66
views
RX implementation of Save() action that would run immediately if 2s has passed since the previous execution or delay it until 2s has passed
var i = 0;
var saveSource = Observable.Interval(TimeSpan.FromMilliseconds(200)).Select(x => i++);
var throttledClicks = saveSource
.Throttle(TimeSpan.FromMilliseconds(2000)) // Throttle for ...
- 1,192
0
votes
0
answers
46
views
Running code within the same thread when cancellation is requested
I have a thread I am starting with Task.Run() - inside of it, I have an observable timer (Observable.Timer) that runs within the context of the same thread. As part of the thread execution, I am using ...
- 16.8k
1
vote
2
answers
218
views
How to sum a property from each element in an ObservableCollection Based on a filter property on each element?
I'm working on a system that has a list of Records displayed in a list.
Each item has the following properties:
Name
Id
Size
A Boolean indicating if this item should be included or not - ...
- 2,345
1
vote
2
answers
79
views
How cancel a debounced Rx event A if a different event B has occured?
I need to cancel a debounced Rx event A if a different event B has occured. A contrived example: ignore a debounced keyboard keystroke if a mouse button was clicked meanwhile.
Below I simulate events ...
- 61.1k
0
votes
0
answers
50
views
.Net Dynamic Data List
I recently started exploring Dynamic Data to try to convert lists of my .net desktop app into dynamic lists because I need for example to have a list of barcodes with properties that change based on ...
- 1
1
vote
1
answer
97
views
How to resample data with Reactive Extensions
I have a large database of of 1minute OHLCV data. I'm trying to aggregate this data, into 1 hour data. The main Idea is to, in the future, replace this offline data source with some live data source, ...
- 61
0
votes
2
answers
365
views
Observable.FromAsync what is IScheduler argument for?
I was trying to execute that Reactive + ReactiveUI Code
Observable.FromAsync(async () => //async code that must run on UI Thread, RxApp.MainThreadScheduler);
But that doesn't get executed on ...
- 33
2
votes
0
answers
184
views
C# WPF run PowerShell async with Reactive and AsyncRelayCommand
I want to use a button click to execute a PowerShell script asynchronously and display the output directly in my UI.
It is based on this StackOverflow question.
Since I couldn't quite figure out the ...
- 339
2
votes
1
answer
272
views
How to create an observable that signals the completion of two other observables?
I have two IObservable<T>, and want to create a IObservable<Unit> (or some sort of ISingle<Unit>, if such a thing exists) that emits a completion signal when both complete, and ...
- 157
-1
votes
1
answer
91
views
Can anyone explain why concatenating many FirstAsync will block completion of parents observables?
I'm working with Reactive and I was testing concatenation.
Unfortunately I wasn't able to understand something.
Can anyone explain why only last onCompleted: is being invoked?
I'm really confused ...
- 33