fluencelabs/fluence-js
1
0
Fork 0
mirror of https://github.com/fluencelabs/fluence-js.git synced 2025-04-25 09:52:12 +00:00
Code Issues Projects Releases Wiki Activity

Immediate -> timeout (#14)

Browse Source
This commit is contained in:
Dima 2021-02-02 14:13:52 +03:00 committed by GitHub
parent 4276ea7c2e
commit e4d3f688ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "@fluencelabs/fluence", "name": "@fluencelabs/fluence",
"version": "0.9.3", "version": "0.9.9",
"description": "JS SDK for the Fluence network", "description": "JS SDK for the Fluence network",
"main": "./dist/index.js", "main": "./dist/index.js",
"typings": "./dist/index.d.ts", "typings": "./dist/index.d.ts",

6
src/api.ts
View File

@ -1,6 +1,6 @@
import { FluenceClient } from './FluenceClient'; import { FluenceClient } from './FluenceClient';
import { SecurityTetraplet } from './internal/commonTypes'; import { SecurityTetraplet } from './internal/commonTypes';
import { genUUID, Particle } from './internal/particle'; import { Particle } from './internal/particle';
import Multiaddr from 'multiaddr'; import Multiaddr from 'multiaddr';
import PeerId, { isPeerId } from 'peer-id'; import PeerId, { isPeerId } from 'peer-id';
import { generatePeerId, seedToPeerId } from './internal/peerIdUtils'; import { generatePeerId, seedToPeerId } from './internal/peerIdUtils';
@ -106,9 +106,9 @@ export const subscribeToEvent = (
): Function => { ): Function => {
const realHandler = (args: any[], tetraplets: SecurityTetraplet[][]) => { const realHandler = (args: any[], tetraplets: SecurityTetraplet[][]) => {
// dont' block // dont' block
setImmediate(() => { setTimeout(() => {
handler(args, tetraplets); handler(args, tetraplets);
}); }, 0);
return {}; return {};
}; };

8
src/internal/FluenceClientImpl.ts
View File

@ -138,10 +138,10 @@ export class FluenceClientImpl extends FluenceClientBase implements FluenceClien
const executingParticlePromiseFns = this.fetchParticles.get(fnName); const executingParticlePromiseFns = this.fetchParticles.get(fnName);
if (executingParticlePromiseFns) { if (executingParticlePromiseFns) {
// don't block // don't block
setImmediate(() => { setTimeout(() => {
this.fetchParticles.delete(fnName); this.fetchParticles.delete(fnName);
executingParticlePromiseFns.resolve(args); executingParticlePromiseFns.resolve(args);
}); }, 0);
} }
return { return {
@ -170,12 +170,12 @@ export class FluenceClientImpl extends FluenceClientBase implements FluenceClien
} }
// don't block // don't block
setImmediate(() => { setTimeout(() => {
this.pushEvent(serviceId, { this.pushEvent(serviceId, {
type: fnName, type: fnName,
args: args, args: args,
}); });
}); }, 0);
return { return {
ret_code: 0, ret_code: 0,