You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Apr 20, 2018. It is now read-only.
I've a strange issue.
I'm creating an observable using the following code.
var contact = _bandService.Sensors.Contact;
var heartBeat = _bandService.Sensors.HeartRate.OnlyWhenWorn(contact);
FakeCondition = heartBeat.Where(h => h.HeartRate > heartRate - 20 & h.Quality == HeartRateQuality.Locked)
.Select(h => new BandState {HeartRate = h.HeartRate, Status = "aaa"});
I verified that I'm reaching the Select statement.
Now on the consumer side I'm subscribing to the observable like this.
Everything is working as expected.
FakeCondition.ObserveOnDispatcher().Subscribe(s =>
{
//DoSomething();
});
but if I had a Throttle construct, I will never receive any calls. Any ideas?
FakeCondition.Throttle(TimeSpan.FromMinutes(5)).ObserveOnDispatcher().Subscribe(s =>
{
//DoSomething();
});
Ariel
The text was updated successfully, but these errors were encountered:
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
I've a strange issue.
I'm creating an observable using the following code.
I verified that I'm reaching the Select statement.
Now on the consumer side I'm subscribing to the observable like this.
Everything is working as expected.
FakeCondition.ObserveOnDispatcher().Subscribe(s =>
{
//DoSomething();
});
but if I had a Throttle construct, I will never receive any calls. Any ideas?
FakeCondition.Throttle(TimeSpan.FromMinutes(5)).ObserveOnDispatcher().Subscribe(s =>
{
//DoSomething();
});
Ariel
The text was updated successfully, but these errors were encountered: