riston/client.html

## client.html
<!DOCTYPE html>
<html>
<head>
    <title>Test websocket</title>
</head>
<script type="text/javascript">
    var context = new webkitAudioContext();
    var ws = new WebSocket("ws://localhost:8080");
    var startTime = context.currentTime;

    ws.binaryType = 'arraybuffer';

    ws.onmessage = function (evt) {
        console.log('Event ', evt);
        context.decodeAudioData(
        evt.data,
            function(buffer) {
                playBuffer(buffer);
                console.log("Success");
            },
            function(error) {
                console.log("Error");
            });
    };

    ws.onopen = function () {
        console.log('Client connection to ws');
    };

    ws.onclose = function () {
        console.log('Connection closed');
    };

    function playBuffer(buf) {
        var source    = context.createBufferSource();
        source.buffer = buf;
        source.connect(context.destination);
        source.start(startTime);
        startTime = startTime+source.buffer.duration;
    }
</script>
<body>

</body>
</html>

## server.js
var fs = require('fs');
var WebSocketServer = require('ws').Server;

var wss = new WebSocketServer({
    port: 8080,
    host: "127.0.0.1"
});

wss.on('connection', function(ws) {
    var readStream =
        fs.createReadStream("/home/risto/Downloads/oleg.mp3", {
            'flags': 'r',
            // 'encoding': 'binary',
            'mode': 0666,
            'bufferSize': 64 * 1024
        });

    readStream.on('data', function(data) {
        ws.send(data, {
            binary: true,
            mask: false
        });
    });
});
	<!DOCTYPE html>
	<html>
	<head>
	<title>Test websocket</title>
	</head>
	<script type="text/javascript">
	var context = new webkitAudioContext();
	var ws = new WebSocket("ws://localhost:8080");
	var startTime = context.currentTime;

	ws.binaryType = 'arraybuffer';

	ws.onmessage = function (evt) {
	console.log('Event ', evt);
	context.decodeAudioData(
	evt.data,
	function(buffer) {
	playBuffer(buffer);
	console.log("Success");
	},
	function(error) {
	console.log("Error");
	});
	};

	ws.onopen = function () {
	console.log('Client connection to ws');
	};

	ws.onclose = function () {
	console.log('Connection closed');
	};

	function playBuffer(buf) {
	var source = context.createBufferSource();
	source.buffer = buf;
	source.connect(context.destination);
	source.start(startTime);
	startTime = startTime+source.buffer.duration;
	}
	</script>
	<body>

	</body>
	</html>
	var fs = require('fs');
	var WebSocketServer = require('ws').Server;

	var wss = new WebSocketServer({
	port: 8080,
	host: "127.0.0.1"
	});

	wss.on('connection', function(ws) {
	var readStream =
	fs.createReadStream("/home/risto/Downloads/oleg.mp3", {
	'flags': 'r',
	// 'encoding': 'binary',
	'mode': 0666,
	'bufferSize': 64 * 1024
	});

	readStream.on('data', function(data) {
	ws.send(data, {
	binary: true,
	mask: false
	});
	});
	});