Skip to content

Commit

Permalink
Improved code.
Browse files Browse the repository at this point in the history
  • Loading branch information
petersirka committed Feb 4, 2025
1 parent 4363bf6 commit 878fb7d
Showing 1 changed file with 4 additions and 12 deletions.
16 changes: 4 additions & 12 deletions flowstream.js
Original file line number Diff line number Diff line change
Expand Up @@ -438,12 +438,8 @@ MP.send = function(outputindex, data, clonedata) {
if (data != undefined)
message.data = data;

if (clonedata && message.data && typeof(message.data) === 'object') {
if (message.data instanceof Buffer)
message.data = Buffer.from(message.data);
else
message.data = F.TUtils.clone(message.data);
}
if (clonedata && message.data && typeof(message.data) === 'object')
message.data = message.data instanceof Buffer ? Buffer.from(message.data) : F.TUtils.clone(message.data);

message.used++;
message.instance = schema;
Expand Down Expand Up @@ -1118,12 +1114,8 @@ FP.ontrigger = function(outputindex, data, controller, events) {
message.used = 1;
}

if (i && (self.cloning != false) && message.data && typeof(message.data) === 'object') {
if (message.data instanceof Buffer)
message.data = Buffer.from(message.data);
else
message.data = F.TUtils.clone(message.data);
}
if (i && (self.cloning != false) && message.data && typeof(message.data) === 'object')
message.data = message.data instanceof Buffer ? Buffer.from(message.data) : F.TUtils.clone(message.data);

message.main = self;
message.controller = controller;
Expand Down

0 comments on commit 878fb7d

Please sign in to comment.