readable

Author: Hussein Nasser

20-streams/201-raw-request-raw-read-stream.js

@@ -1,19 +1,16 @@
-const http = require("node:http");
+const http = require("node:https");
 //request object is a writable stream
-const req = http.request("http://example.com",  { "method": "GET"});
+//large json
+const req = http.request("https://raw.githubusercontent.com/json-iterator/test-data/refs/heads/master/large-file.json",  { "method": "GET"});
 
 req.on("response", res => {
         //we tell node that we want to read this ourselves.. 
         //for that we attach a readable event 
+        //this will be called everytime there is something to read
         res.on("readable", ()=> {
             let x = res.read();
-            console.log(x.toString())
-            //when read returns null we are done.
-            while(x != null)
-            {
-                console.log(x.toString());
-                x = res.read();
-            }
+            if (x == null) return; //quit if its null
+            console.log(x.toString().length)
         })
         //call also assign an end event 
         res.on("end", ()=>console.log("response fully read! "))

20-streams/202-raw-httpserver.js

@@ -4,9 +4,9 @@ const http = require("node:http");
 //run with default, send this request
 // head -c 10240000 /dev/zero | curl -X POST --data-binary http://192.168.7.179:8080
 //then run with the overriden hwm
-//const server = http.createServer({"highWaterMark": 300_000} );
+const server = http.createServer({"highWaterMark": 300_000} );
 
-const server = http.createServer( );
+//const server = http.createServer( );
 
 server.on("request", (req, res) => {
     //default is 65536
@@ -16,12 +16,11 @@ server.on("request", (req, res) => {
     //body is not read by default (can be large)
    req.on("readable", () => {
           function readChunk() {
-
-          //delay reading so we fill up the stream buffer.
-	  let chunk = req.read(); 
-	  if (chunk == null) return;
-	   console.log("reading..." + chunk.toString().length);
-	  } 
+            //delay reading so we fill up the stream buffer.
+            let chunk = req.read(); 
+            if (chunk == null) return;
+            console.log("reading..." + chunk.toString().length);
+           } 
          //read every second so the _read is called
 	 setTimeout(readChunk, 1000);