Rx debounceTime doesn't work.

[tandu]

I have modified example from here ReactiveX/rxjs#916 -> http://jsfiddle.net/889byemb/. It works as expected. I have created service that should only notify after 1.5s after scroll end and it is never fired.

import {EventEmitter} from 'angular2/core';
import 'rxjs/add/operator/debounceTime.js';

export class ScrollService {
  scrolled = new EventEmitter().debounceTime(1500);
}

using service from another component

<holder (scroll)="scrollService.scrolled.next()"></holder>

If I replace debounceTime by throttleTime events are fired fine but I need debounce behavior not the throttle one. I think there might be an issue in angular because the jsfiddle example above with pure rx is working as expected.

[robwormald]

Could you reproduce this in a plunker?

[tandu]

I will do it tomorrow.

[tandu]

I have tried to create the plunker: http://plnkr.co/edit/Blgmi6CTo1v9puIQSLAI?p=preview. I don't know how to add debounceTime method here, can you complete it yourself?

[robwormald]

This is more to do with the fact you're using a Subject (don't use EventEmitter here either, fwiw) than anything to do with Angular2.

See http://jsfiddle.net/8g968xh7/ which exhibits the same behavior.

The correct-ish way to do the same thing in your original fiddle would be something like this http://plnkr.co/edit/0pldDi0TSqS69rsWOmZ8?p=preview (using Observable.fromEvent). Ideally we'd like to make this easier, getting proper Observables from the view. See #4062 for info on that.

@Blesh would this be the expected behavior on a Subject? seems kinda weird.

[tandu]

Thank you for explanation. It looks strange because throttleTime is working and debounceTime doesn't with Subject. I will create related issue in rxjs.

[jorgeunimicro]

I have the same problem. Here is the plunker: http://plnkr.co/edit/UCi63b?p=preview

[robwormald]

@jorgeunimicro you're importing your operator wrong: http://plnkr.co/edit/IoV11B?p=preview

[jorgeunimicro]

still doesn't work. Validation keep being false

[tandu]

So far it seems that fix is to pass anything when you emit event, for example if instead of scrollService.scrolled.next() you emit scrollService.scrolled.next(0) or scrollService.scrolled.next('a') everything works fine.

[jorgeunimicro]

But, I can't handle what a Controls emit. That depends on the user input

[jorgeunimicro]

@robwormald I import the operator in a correct way. It is defined (see console.log). But still doesn't work even if I import from add/operator instead of operator. http://plnkr.co/edit/UCi63b?p=preview

[jorgeunimicro]

@robwormald it seems start validation throws an exception because c.valueChanges is undefined.

http://plnkr.co/edit/tRfGWb?p=preview

[benlesh]

This is likely a bug with RxJS beta.

[benlesh]

File an issue over there, and we'll take a look. The holiday season will slow things down a bit though

[pkozlowski-opensource]

This one sounds like stale. Closing for now.

[angular-automatic-lock-bot]

This issue has been automatically locked due to inactivity.
Please file a new issue if you are encountering a similar or related problem.

Read more about our automatic conversation locking policy.

_{This action has been performed automatically by a bot.}