Skip to content

Commit 41b2741

Browse files
committed
add optionnal callback
1 parent 0cffff0 commit 41b2741

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

js/embark.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -263,11 +263,11 @@ EmbarkJS.Messages.sendMessage = function(options) {
263263
return this.currentMessages.sendMessage(options);
264264
};
265265

266-
EmbarkJS.Messages.listenTo = function(options) {
266+
EmbarkJS.Messages.listenTo = function(options, callback) {
267267
if (!this.currentMessages) {
268268
throw new Error('Messages provider not set; e.g EmbarkJS.Messages.setProvider("whisper")');
269269
}
270-
return this.currentMessages.listenTo(options);
270+
return this.currentMessages.listenTo(options, callback);
271271
};
272272

273273
EmbarkJS.Utils = {

lib/modules/whisper/js/embarkjs.js

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ __embarkWhisperNewWeb3.sendMessage = function (options) {
6464
});
6565
};
6666

67-
__embarkWhisperNewWeb3.listenTo = function (options) {
67+
__embarkWhisperNewWeb3.listenTo = function (options, callback) {
6868
var topics = options.topic || options.topics;
6969

7070
let promise = new __MessageEvents();
@@ -82,12 +82,15 @@ __embarkWhisperNewWeb3.listenTo = function (options) {
8282
var payload = JSON.parse(EmbarkJS.Utils.toAscii(result.payload));
8383
var data;
8484
data = {
85-
topic: result.topic,
85+
topic: EmbarkJS.Utils.toAscii(result.topic),
8686
data: payload,
8787
//from: result.from,
8888
time: result.timestamp
8989
};
9090

91+
if (callback) {
92+
return callback(null, data);
93+
}
9194
promise.cb(payload, data, result);
9295
});
9396

0 commit comments

Comments
 (0)