util.promisify.custom and http.get example

promisify-http.js

const http = require('http');
const {promisify} = require('util');

http.get[promisify.custom] = function getAsync(options) {
  return new Promise((resolve, reject) => {
    http.get(options, (response) => {
      response.end = new Promise((resolve) => response.on('end', resolve));
      resolve(response);
    }).on('error', reject);
  });
};

const get = promisify(http.get);

(async () => {
  try {
    const response = await get('http://krnl.de/');
    let body = '';
    response.on('data', (chunk) => body += chunk);
    await response.end;
    console.log(body);
  } catch(e) {
    // statements
    console.log(e);
  }
})();

Nice snippet!
One suggestion.

From:

response.on('data', (chunk) => body += chunk);
await response.end;

To:

for await (const chunk of response) {
  body += chunk
}

Done :)

const http = require('http');
const { promisify } = require('util');

function makeDeferred() {
  let resolve;
  let reject;

  const promise = new Promise((res, rej) => {
    resolve = res;
    reject = rej;
  });

  return {resolve, reject, promise};
}

http.get[promisify.custom] = function getAsync(options) {
  return new Promise((resolve, reject) => {
    http.get(options, (response) => {
      async function* iterator() {
        let ended = false;
        let next = makeDeferred();

        response.on('end', () => ended = true);
        response.on('error', (e) => next.reject(e));
        response.on('data', (chunk) => {
          next.resolve(chunk);
          next = makeDeferred();
        });

        while (!ended) {
          yield await next.promise;
        }
      }

      resolve(iterator());
    }).on('error', reject);
  });
};

/////////////////////////////////////////////

const get = promisify(http.get);

(async () => {
  try {
    const response = await get('http://google.com/');
    let body = '';
    for await (const chunk of response) {
      body += chunk;
    }
    console.log(body);
  } catch(e) {
    // statements
    console.log(e);
  }
})();

Nice snippet! One suggestion.

From:

response.on('data', (chunk) => body += chunk);
await response.end;

To:

for await (const chunk of response) {
  body += chunk
}

awesome!!! (╹ڡ╹ )