Row of Observables

Question

Row of Observables

Navigation

#1 by (0 votes)

-1

My application has a service that runs an observable every time I click a button. The problem is that if I click the button several times it executes the Observable several times at the same time. He needed this service to line up and run one at a time. What better way to do this?

EDIT: Source

// component
onClick(record){
  this.myService.updateRecord(params).subscribe();
}

// service
updateRecord(record){
  return new Observable((observer) => {
    Observable.forkJoin(
      Observable.fromPromise(this.storage.get('things')),
      Observable.fromPromise(this.storage.get('other_things'))
    ).subscribe(
      (results) => {
        let things = results[0] || []
        let other_things = results[1] || []

        // do stuffs 

        observer.next([record])
        observer.complete()
      })
  })
}

angular

asked by anonymous 18.10.2017 / 16:14

1 answer

Undefined property return in javascript model Is it possible to create a Widget with several configuration screens?

score 0 · Accepted Answer

Resolved based on this response: link

// component
onClick(record){
  this.myService._updateRecord(params).subscribe();
}

// service
private trigger= undefined;

updateRecord(record){
  return new Observable((observer) => {
    Observable.forkJoin(
      Observable.fromPromise(this.storage.get('things')),
      Observable.fromPromise(this.storage.get('other_things'))
    ).subscribe(
      (results) => {
        let things = results[0] || []
        let other_things = results[1] || []

        // do stuffs 

        observer.next([record])
        observer.complete()
      })
  })
}

obsQueue(record) {
  if (!this.trigger || this.trigger.isStopped) {
    this.trigger = new Subject();
    return this.createObservable(this.trigger, record);
  } else {
    var lastTrigger = this.trigger;
    var newTrigger = this.trigger = new Subject();
    return lastTrigger.last().mergeMap(() => {
      return this.createObservable(newTrigger, record);
    });
  }
}


createObservable(trigger, record) {
  return this.updateRecord(record).finally(() => {
    trigger.next();
    trigger.complete();
  });
}


_updateRecord(record){
  return this.obsQueue(record);
}