@@ -176,10 +176,13 @@ server.post("withCreateProcess", (request) => {
176
176
tmp . file ( ( err , path , fd ) => {
177
177
if ( err ) throw err ;
178
178
179
- const reader = fs . createReadStream ( path ) ;
180
-
181
- reader . on ( "open" , ( ) => {
182
179
nextCounter += 1 ;
180
+
181
+ fs . createReadStream ( path )
182
+ . on ( "data" , ( chunk ) => {
183
+ processes [ nextCounter ] . stdin . end ( chunk ) ;
184
+ } ) ;
185
+
183
186
processes [ nextCounter ] = child_process . spawn (
184
187
createProcess . cmdspec . cmd ,
185
188
createProcess . cmdspec . args ,
@@ -194,11 +197,6 @@ server.post("withCreateProcess", (request) => {
194
197
195
198
request . respond ( 200 , null , JSON . stringify ( { stdinHandle : fd , ph : nextCounter } ) ) ;
196
199
} ) ;
197
-
198
- reader . on ( "data" , ( chunk ) => {
199
- processes [ nextCounter ] . stdin . end ( chunk ) ;
200
- } ) ;
201
- } ) ;
202
200
} ) ;
203
201
204
202
server . post ( "hClose" , ( request ) => {
@@ -208,7 +206,8 @@ server.post("hClose", (request) => {
208
206
} ) ;
209
207
210
208
server . post ( "waitForProcess" , ( request ) => {
211
- processes [ request . body ] . on ( "exit" , ( code ) => {
209
+ const ph = parseInt ( request . body ) ;
210
+ processes [ ph ] . on ( "exit" , ( code ) => {
212
211
request . respond ( 200 , null , code ) ;
213
212
} ) ;
214
213
} ) ;
0 commit comments