socket-observer

Simple RXJS wrapper around node's net.Socket.

Installation

npm install --save socket-observer

Example usage

With user-provided socket:

import { createConnection } from 'net';
import { socketObserver } from 'socket-observer';

const socket = createConnection({
    host: 'example.com',
    port: 80
});
const oSocket = socketObserver(socket);
oSocket.down.subscribe(console.log);
oSocket.up('GET / HTTP/1.1\nHost: example.com\n\n');

Or using createConnection helper:

import { createConnection } from 'socket-observer';

const oSocket = createConnection({
    host: 'example.com',
    port: 80
});
oSocket.down.subscribe(console.log);
oSocket.up('GET / HTTP/1.1\nHost: example.com\n\n');