Fix stdin

example/package.json

@@ -5,7 +5,7 @@
   "scripts": {
     "build": "tsc",
     "install": "npm run build",
-    "test": "npm run build && webpack && node build/main.js"
+    "test": "npm run build && webpack && (echo bar | node build/main.js)"
   },
   "author": "Will Fancher",
   "dependencies": {

example/src/index.ts

@@ -9,6 +9,10 @@ class JSaddleDevice implements Device {
 
 configureFileSystem({ "/jsaddle": new JSaddleDevice() }, (err, fs) => {
   console.log(err);
-  let buf = Buffer.from("hi\n");
-  fs.write(1, buf, 0, buf.length, null, () => {});
+  let buf = Buffer.from("foo\n");
+  fs.write(1, buf, 0, buf.length, null, () => {
+    fs.read(0, buf, 0, 4, null, (err, n, buf) => {
+      console.log({ err: err, n: n, buf: buf && buf.toString() });
+    });
+  });
 });

example/webpack.config.js

@@ -12,5 +12,8 @@ module.exports = {
   resolve: {
     // Using file:../kernel in package.json requires this
     symlinks: false
+  },
+  node: {
+    process: false
   }
 };

kernel/src/stdio_handles.ts

@@ -79,9 +79,9 @@ if (process && !(process as any).browser) {
 
     onData(buf: Buffer): void {
       const reqs = this.requests;
-      this.requests = <[Request]> [];
       let nextBuf: Buffer | null = null;
-      for (const req of reqs) {
+      let req: Request;
+      while (req = this.requests.shift()) {
         if (buf.length > req.length) {
           nextBuf = buf.slice(req.length);
           buf = buf.slice(0, req.length);
@@ -92,6 +92,9 @@ if (process && !(process as any).browser) {
         const copied = buf.copy(req.buffer, req.offset);
         req.cb(undefined, copied, req.buffer);
 
+        if (!nextBuf || nextBuf.length == 0) {
+          break;
+        }
         buf = nextBuf;
       }