diff --git a/‎src/connect/connect-echo-example.js‎
Lines changed: 33 additions & 0 deletions b/‎src/connect/connect-echo-example.js‎
Lines changed: 33 additions & 0 deletions
diff --git a/‎src/connect/connect-example.js‎
Lines changed: 7 additions & 4 deletions b/‎src/connect/connect-example.js‎
Lines changed: 7 additions & 4 deletions
diff --git a/‎src/connect/connect-inline-example.js‎
Lines changed: 0 additions & 23 deletions b/‎src/connect/connect-inline-example.js‎
Lines changed: 0 additions & 23 deletions
@@ -0,0 +1,33 @@
+"use strict";
+import connect from "connect";
+import http from "http";
+import assert from "assert";
+var app = connect();
+// add Error handling
+app.use(function (err, req, res, next) {
+    console.error(err.stack);
+    res.status(500).send(err.message);
+    next();
+});
+// request to response
+app.use(function (req, res) {
+    req.pipe(res);
+});
+//create node.js http server and listen on port
+var server = http.createServer(app).listen(3000, request);
+
+// request => response
+function request() {
+    var requestBody = {
+        "key": "value"
+    };
+    fetch("http://localhost:3000", {
+        method: "POST",
+        body: JSON.stringify(requestBody)
+    })
+        .then(res => res.text())
+        .then(text => {
+            assert.deepEqual(text, requestBody);
+            server.close();
+        }).catch(console.error.bind(console));
+}
@@ -8,17 +8,20 @@ import http from "http";
 import fetch from "node-fetch";
 const responseText = "response text";
 var app = connect();
+// add Error handling
 app.use(errorHandler());
+// add "X-Content-Type-Options" to response
 app.use(nosniff());
+// respond to all requests
 app.use(hello(responseText));
+//create node.js http server and listen on port
+var server = http.createServer(app).listen(3000, request);
 
-var server = http.createServer(app).listen(3000, () => {
+function request() {
     fetch("http://localhost:3000")
         .then(res => res.text())
         .then(text => {
             assert.equal(text, responseText);
             server.close();
         }).catch(console.error.bind(console));
-});
-
-
+}