1.0.0-beta.1

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "http2-wrapper",
-	"version": "1.0.0-beta.0",
+	"version": "1.0.0-beta.1",
 	"description": "HTTP2 client, just with the familiar `https` API",
 	"main": "source",
 	"engines": {
@@ -40,7 +40,7 @@
 		"coveralls": "^3.0.5",
 		"create-cert": "^1.0.6",
 		"get-stream": "^5.1.0",
-		"got": "^9.6.0",
+		"got": "^10.0.0-alpha.3",
 		"lolex": "^4.2.0",
 		"many-keys-map": "^1.0.2",
 		"nyc": "^14.1.1",

source/agent.js

@@ -1,4 +1,5 @@
 'use strict';
+const EventEmitter = require('events');
 const tls = require('tls');
 const http2 = require('http2');
 const QuickLRU = require('quick-lru');
@@ -117,8 +118,10 @@ const closeSessionIfCovered = (where, name, coveredSession) => {
 	}
 };
 
-class Agent {
+class Agent extends EventEmitter {
 	constructor({timeout = 60000, maxSessions = Infinity, maxFreeSessions = 1, maxCachedTlsSessions = 100} = {}) {
+		super();
+
 		// A session is considered busy when its current streams count
 		// is equal to or greater than the `maxConcurrentStreams` value.
 		this.busySessions = {};
@@ -430,6 +433,8 @@ class Agent {
 							return;
 						}
 
+						this.emit('session', session);
+
 						if (freeSession()) {
 							// Process listeners, we're free.
 							processListeners();

source/client-request.js

@@ -221,7 +221,7 @@ class ClientRequest extends Writable {
 
 			// This event tells we are ready to listen for the data.
 			this._request.once('response', (headers, flags, rawHeaders) => {
-				this.res = new IncomingMessage(this.socket);
+				this.res = new IncomingMessage(this.connection);
 				this.res.req = this;
 				this.res.statusCode = headers[HTTP2_HEADER_STATUS];
 				this.res.headers = headers;
@@ -271,7 +271,7 @@ class ClientRequest extends Writable {
 			this.connection = this._request.session.socket;
 
 			process.nextTick(() => {
-				this.emit('socket', this._request.session.socket);
+				this.emit('socket', this.connection);
 			});
 		};