mkarkowski/nope
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

removing console logs

Browse Source
This commit is contained in:
martin 2020-11-15 20:21:02 +01:00
parent a5b82ebb9e
commit 4761734d5f
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/dispatcher/nopeDispatcher.ts
View File

@ -522,7 +522,7 @@ export class nopeDispatcher implements INopeDispatcher {
if (this._logger?.isErrorEnabled()){ if (this._logger?.isErrorEnabled()){
this._logger.error('Failed with task ' + data.taskId); this._logger.error('Failed with task ' + data.taskId);
this._logger.error('Reason: ' + data.error.msg); this._logger.error('Reason: ' + data.error.msg);
console.log(data.error.error); console.error(data.error.error);
} }
task.reject(data.error); task.reject(data.error);
@ -1197,12 +1197,9 @@ export class nopeDispatcher implements INopeDispatcher {
pipe: options.pipe pipe: options.pipe
}); });
console.log('SUBSCRIBING',event)
// Create an Observer by susbcribing to the external source (this is directly linked to the System) // Create an Observer by susbcribing to the external source (this is directly linked to the System)
const observer = observable.subscribe( const observer = observable.subscribe(
event => { event => {
console.log('CB OF ELEMENT HIER:')
callback(event.data, event.sender, event.timestamp); callback(event.data, event.sender, event.timestamp);
}, },
options.mode, options.mode,
@ -1327,8 +1324,7 @@ export class nopeDispatcher implements INopeDispatcher {
if (options.mode == 'publish' || (Array.isArray(options.mode) && options.mode.includes('publish'))) { if (options.mode == 'publish' || (Array.isArray(options.mode) && options.mode.includes('publish'))) {
const cb = (data, sender?, timestamp?, ...args) => { const cb = (data, sender?, timestamp?, ...args) => {
// Only Publish data, if there exists a Subscription. // Only Publish data, if there exists a Subscription.
console.log(_pubTopic, _this.subscriptionExists(_pubTopic), _this.id !== sender); if (_this.subscriptionExists(_pubTopic) && _this.id !== sender) {
if (true || _this.subscriptionExists(_pubTopic) && _this.id !== sender) {
// Use the Communicator to emit the Event. // Use the Communicator to emit the Event.
_this._communicator.emitEvent(_pubTopic, { _this._communicator.emitEvent(_pubTopic, {
data: data, data: data,

2
lib/helpers/runtimeMethods.ts
View File

@ -21,7 +21,7 @@ export const callImmediate = _runningInNode ? (callback: (...args) => void, ...a
try { try {
callback(...args); callback(...args);
} catch (error) { } catch (error) {
console.log(error); console.error(error);
} }
}); });
} : (callback: (...args) => void, ...args) => { } : (callback: (...args) => void, ...args) => {