- let producers: Array<EIProducer> = [];
- this.eiSvc.getProducerIds()
- .subscribe((prodIds: string[]) => {
- console.log("ProducerIds: " + prodIds);
- prodIds.forEach(id => {
- let eiProducer = <EIProducer>{};
- eiProducer.ei_producer_id = id;
- this.eiSvc.getProducer(id).subscribe(producer => {
- eiProducer.ei_producer_types = producer.supported_ei_types;
- });
- this.eiSvc.getProducerStatus(id).subscribe(prodStatus => {
- eiProducer.status = prodStatus.opState.toString();
- });
- this.addProducerToSubject(eiProducer);
- producers.push(eiProducer);
- });
- this.rowCount = this.producerSubject.value.length;
- });
- return of(producers);
- }