Skip to content

Commit e4d3f68

Browse files
authored
Immediate -> timeout (#14)
1 parent 4276ea7 commit e4d3f68

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@fluencelabs/fluence",
3-
"version": "0.9.3",
3+
"version": "0.9.9",
44
"description": "JS SDK for the Fluence network",
55
"main": "./dist/index.js",
66
"typings": "./dist/index.d.ts",

src/api.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { FluenceClient } from './FluenceClient';
22
import { SecurityTetraplet } from './internal/commonTypes';
3-
import { genUUID, Particle } from './internal/particle';
3+
import { Particle } from './internal/particle';
44
import Multiaddr from 'multiaddr';
55
import PeerId, { isPeerId } from 'peer-id';
66
import { generatePeerId, seedToPeerId } from './internal/peerIdUtils';
@@ -106,9 +106,9 @@ export const subscribeToEvent = (
106106
): Function => {
107107
const realHandler = (args: any[], tetraplets: SecurityTetraplet[][]) => {
108108
// dont' block
109-
setImmediate(() => {
109+
setTimeout(() => {
110110
handler(args, tetraplets);
111-
});
111+
}, 0);
112112

113113
return {};
114114
};

src/internal/FluenceClientImpl.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -138,10 +138,10 @@ export class FluenceClientImpl extends FluenceClientBase implements FluenceClien
138138
const executingParticlePromiseFns = this.fetchParticles.get(fnName);
139139
if (executingParticlePromiseFns) {
140140
// don't block
141-
setImmediate(() => {
141+
setTimeout(() => {
142142
this.fetchParticles.delete(fnName);
143143
executingParticlePromiseFns.resolve(args);
144-
});
144+
}, 0);
145145
}
146146

147147
return {
@@ -170,12 +170,12 @@ export class FluenceClientImpl extends FluenceClientBase implements FluenceClien
170170
}
171171

172172
// don't block
173-
setImmediate(() => {
173+
setTimeout(() => {
174174
this.pushEvent(serviceId, {
175175
type: fnName,
176176
args: args,
177177
});
178-
});
178+
}, 0);
179179

180180
return {
181181
ret_code: 0,

0 commit comments

Comments
 (0)