Code Review
/
portal
/
nonrtric-controlpanel.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "Fix the Nginx conf to start even when Upstream is unavailable"
[portal/nonrtric-controlpanel.git]
/
webapp-frontend
/
src
/
app
/
ei-coordinator
/
ei-producer.datasource.ts
diff --git
a/webapp-frontend/src/app/ei-coordinator/ei-producer.datasource.ts
b/webapp-frontend/src/app/ei-coordinator/ei-producer.datasource.ts
index
255c555
..
8dac859
100644
(file)
--- a/
webapp-frontend/src/app/ei-coordinator/ei-producer.datasource.ts
+++ b/
webapp-frontend/src/app/ei-coordinator/ei-producer.datasource.ts
@@
-31,10
+31,10
@@
import { EIService } from '../services/ei/ei.service';
export class EIProducerDataSource {
export class EIProducerDataSource {
- private producer
Subject = new BehaviorSubject<EIProducer[]>([])
;
+ private producer
s: Array<EIProducer> = []
;
public eiProducers(): EIProducer[] {
public eiProducers(): EIProducer[] {
- return this.producer
Subject.value
;
+ return this.producer
s
;
}
private loadingSubject = new BehaviorSubject<boolean>(false);
}
private loadingSubject = new BehaviorSubject<boolean>(false);
@@
-49,7
+49,7
@@
export class EIProducerDataSource {
loadProducers() {
this.loadingSubject.next(true);
loadProducers() {
this.loadingSubject.next(true);
-
let producers: Array<EIProducer>
= [];
+
this.producers
= [];
this.eiSvc.getProducerIds()
.subscribe((prodIds: string[]) => {
console.log("ProducerIds: " + prodIds);
this.eiSvc.getProducerIds()
.subscribe((prodIds: string[]) => {
console.log("ProducerIds: " + prodIds);
@@
-62,16
+62,9
@@
export class EIProducerDataSource {
this.eiSvc.getProducerStatus(id).subscribe(prodStatus => {
eiProducer.status = prodStatus.opState.toString();
});
this.eiSvc.getProducerStatus(id).subscribe(prodStatus => {
eiProducer.status = prodStatus.opState.toString();
});
- this.addProducerToSubject(eiProducer);
- producers.push(eiProducer);
+ this.producers.push(eiProducer);
});
});
- this.rowCount = this.producer
Subject.value
.length;
+ this.rowCount = this.producer
s
.length;
});
}
});
}
-
- private addProducerToSubject(producer: EIProducer) {
- const currentValue = this.producerSubject.value;
- const updatedValue = [...currentValue, producer];
- this.producerSubject.next(updatedValue);
- }
}
\ No newline at end of file
}
\ No newline at end of file