push.rocks/smartspawn
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz
2019-04-08 15:39:17 +02:00
parent 904309564a
commit 77ad483a8a
5 changed files with 311 additions and 314 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ts/smartspawn.classes.thread.ts
View File

@ -1,6 +1,6 @@
import * as plugins from './smartspawn.plugins';
import * as paths from './smartspawn.paths';
import * as q from 'smartq';
import * as smartpromise from '@pushrocks/smartpromise';
import { Pool } from './smartspawn.classes.pool';
import { startSpawnWrap, endSpawnWrap } from './smartspawn.wrap';
@ -30,7 +30,7 @@ export class Thread {
* spawns it and keeps running
*/
send<T>(message: any): Promise<T> {
let done = q.defer<T>();
let done = smartpromise.defer<T>();
this._checkSpawn();
this.thread.send(message);
this.thread.on('message', (message: T) => {
@ -49,7 +49,7 @@ export class Thread {
* sends a command once and then kills the child process
*/
sendOnce<T>(message): Promise<T> {
let done = q.defer<T>();
let done = smartpromise.defer<T>();
this.send<T>(message).then(message => {
done.resolve(message);
this.kill();

5
ts/smartspawn.classes.threadfunction.ts
View File

@ -1,6 +1,5 @@
import 'typings-global';
import * as plugins from './smartspawn.plugins';
import * as q from 'smartq';
import * as smartpromise from '@pushrocks/smartpromise';
export interface IThreadFunction {
(input, done): void;
@ -16,7 +15,7 @@ export class ThreadFunction {
* sends a message to the spawned process
*/
send<T>(message: any): Promise<T> {
let done = q.defer<T>();
let done = smartpromise.defer<T>();
this.thread
.send(message)
.on('message', (message: T) => {

4
ts/smartspawn.classes.threadsimple.ts
View File

@ -1,5 +1,5 @@
import * as plugins from './smartspawn.plugins';
import * as smartq from 'smartq';
import * as smartpromise from '@pushrocks/smartpromise';
import * as childProcess from 'child_process';
import { workerBasePath } from './smartspawn.classes.thread';
@ -20,7 +20,7 @@ export class ThreadSimple {
}
run() {
let done = smartq.defer<childProcess.ChildProcess>();
let done = smartpromise.defer<childProcess.ChildProcess>();
let forkPath = (() => {
if (workerBasePath) {
return plugins.path.join(workerBasePath, this.workerPath);