From fea769a2718c99a873dea03427fca0bd355cd2af Mon Sep 17 00:00:00 2001
From: AJ ONeal <aj@daplie.com>
Date: Fri, 28 Apr 2017 12:24:39 -0600
Subject: [PATCH] create writer synchronously, win detection fix

---
 README.md          | 10 +++++-----
 lib/socket-pair.js | 10 ++++++----
 2 files changed, 11 insertions(+), 9 deletions(-)

diff --git a/README.md b/README.md
index 79e9912..1d5def9 100644
--- a/README.md
+++ b/README.md
@@ -11,12 +11,12 @@ Similar to `stream-pair`, but with sockets with real fds. A workaround for <http
 ```javascript
 var socketPair = require('socket-pair');
 
-socketPair.create(function (err, pair) {
-  var a = pair.client;      // as in `client = net.connect()`
-  var b = pair.connection;  // as in `server.on('connection', function (conn) { ... })`
+var socket = socketPair.create(function (err, other) {
+  // socket as in `client = net.connect()`
+  // other as in `server.on('connection', function (conn) { ... })`
 
-  a.write('123');
-  b.on('data', function (chunk) {
+  socket.write('123');
+  other.on('data', function (chunk) {
     console.log(chunk.toString('utf8'));
   });
 
diff --git a/lib/socket-pair.js b/lib/socket-pair.js
index c7f9900..1e3371e 100644
--- a/lib/socket-pair.js
+++ b/lib/socket-pair.js
@@ -10,7 +10,7 @@ function createServer(cb, prefix) {
 	var path = require('path');
   var sockname = (prefix || 'node-socket-pair') + '.' + require('crypto').randomBytes(16).toString('hex') + '.sock';
 
-  if (/win/.test(os.platform())) {
+  if (/^win/.test(os.platform())) {
     sock = path.join('\\\\?\\pipe', process.cwd(), sockname);
   }
   else {
@@ -30,13 +30,13 @@ function createServer(cb, prefix) {
 
 exports.create = function create(cb, prefix) {
 	var net = require('net');
-	var client;
+	var client = new net.Socket();
 
   function createConnection() {
     function onClientError(err) {
       cb(err);
     }
-    client = net.connect(sock, function () {
+    client.connect(sock, function () {
       client.removeListener('error', onClientError);
     });
     client.once('error', onClientError);
@@ -48,7 +48,7 @@ exports.create = function create(cb, prefix) {
   }
 
   server.once('connection', function onEach(connection) {
-    cb(null, { client: client, connection: connection });
+    cb(null, connection);
   });
 
   if (!listening) {
@@ -57,6 +57,8 @@ exports.create = function create(cb, prefix) {
   else {
     createConnection();
   }
+
+  return client;
 };
 
 exports.closeAll = function () {