forked from RnD/rotatingMachine
Rename _updateSourceSink to updateSourceSink for outside access
This commit is contained in:
@@ -509,7 +509,7 @@ class Machine {
|
|||||||
this.logger.debug(`Flow update: ${value} at ${position} from ${context.childName || 'child'}`);
|
this.logger.debug(`Flow update: ${value} at ${position} from ${context.childName || 'child'}`);
|
||||||
|
|
||||||
if (this.upstreamSource && this.downstreamSink) {
|
if (this.upstreamSource && this.downstreamSink) {
|
||||||
this._updateSourceSink();
|
this.updateSourceSink();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Store in parent's measurement container
|
// Store in parent's measurement container
|
||||||
@@ -521,7 +521,7 @@ class Machine {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
_updateSourceSink() {
|
updateSourceSink() {
|
||||||
// Handles flow according to the configured "flow number"
|
// Handles flow according to the configured "flow number"
|
||||||
this.logger.debug(`Updating source-sink pair: ${this.upstreamSource.config.functionality.softwareType} - ${this.downstreamSink.config.functionality.softwareType}`);
|
this.logger.debug(`Updating source-sink pair: ${this.upstreamSource.config.functionality.softwareType} - ${this.downstreamSink.config.functionality.softwareType}`);
|
||||||
this.downstreamSink.setInfluent = this.upstreamSource.getEffluent[this.config.flowNumber];
|
this.downstreamSink.setInfluent = this.upstreamSource.getEffluent[this.config.flowNumber];
|
||||||
|
|||||||
Reference in New Issue
Block a user