From d08bd46714a7212d7ee8ab9eba00750d34eb2f9d Mon Sep 17 00:00:00 2001
From: Robert Nagy <ronagy@icloud.com>
Date: Sun, 14 Jul 2019 18:13:08 +0200
Subject: [PATCH] http: writableFinished

---
 doc/api/http.md                               |  9 ++++++
 lib/_http_outgoing.js                         |  9 ++++++
 .../test-http-outgoing-writableFinished.js    | 32 +++++++++++++++++++
 3 files changed, 50 insertions(+)
 create mode 100644 test/parallel/test-http-outgoing-writableFinished.js

diff --git a/doc/api/http.md b/doc/api/http.md
index cc0c7ae1ce4917..26b6d18df49cec 100644
--- a/doc/api/http.md
+++ b/doc/api/http.md
@@ -1458,6 +1458,15 @@ Returns `true` if the entire data was flushed successfully to the kernel
 buffer. Returns `false` if all or part of the data was queued in user memory.
 `'drain'` will be emitted when the buffer is free again.
 
+### response.writableFinished
+<!-- YAML
+added: REPLACEME
+-->
+
+* {boolean}
+
+Is `true` if all data has been flushed to the underlying system.
+
 ### response.writeContinue()
 <!-- YAML
 added: v0.3.0
diff --git a/lib/_http_outgoing.js b/lib/_http_outgoing.js
index a4a2b3ab144400..ef7c8c65772b9d 100644
--- a/lib/_http_outgoing.js
+++ b/lib/_http_outgoing.js
@@ -109,6 +109,15 @@ function OutgoingMessage() {
 Object.setPrototypeOf(OutgoingMessage.prototype, Stream.prototype);
 Object.setPrototypeOf(OutgoingMessage, Stream);
 
+Object.defineProperty(OutgoingMessage.prototype, 'writableFinished', {
+  get: function() {
+    return (
+      this.finished &&
+      this.outputSize === 0 &&
+      (!this.socket || this.socket.writableLength === 0)
+    );
+  }
+});
 
 Object.defineProperty(OutgoingMessage.prototype, '_headers', {
   get: internalUtil.deprecate(function() {
diff --git a/test/parallel/test-http-outgoing-writableFinished.js b/test/parallel/test-http-outgoing-writableFinished.js
new file mode 100644
index 00000000000000..6f84d91e714790
--- /dev/null
+++ b/test/parallel/test-http-outgoing-writableFinished.js
@@ -0,0 +1,32 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const http = require('http');
+
+const server = http.createServer(common.mustCall(function(req, res) {
+  assert.strictEqual(res.writableFinished, false);
+  res
+    .on('finish', common.mustCall(() => {
+      assert.strictEqual(res.writableFinished, true);
+      server.close();
+    }))
+    .end();
+}));
+
+server.listen(0);
+
+server.on('listening', common.mustCall(function() {
+  const clientRequest = http.request({
+    port: server.address().port,
+    method: 'GET',
+    path: '/'
+  });
+
+  assert.strictEqual(clientRequest.writableFinished, false);
+  clientRequest
+    .on('finish', common.mustCall(() => {
+      assert.strictEqual(clientRequest.writableFinished, true);
+    }))
+    .end();
+  assert.strictEqual(clientRequest.writableFinished, false);
+}));