diff --git a/examples/autobahn_client.js b/examples/autobahn_client.js index c152b74..47034dc 100644 --- a/examples/autobahn_client.js +++ b/examples/autobahn_client.js @@ -17,24 +17,24 @@ socket.onclose = function() { if (n > cases) { socket = new WebSocket.Client(host + '/updateReports?agent=' + encodeURIComponent(agent)); socket.onclose = process.exit - + } else if (skip.indexOf(n) >= 0) { runCase(n + 1); - + } else { console.log('Running test case #' + n + ' ...'); socket = new WebSocket.Client(host + '/runCase?case=' + n + '&agent=' + encodeURIComponent(agent)); - + socket.onmessage = function(event) { socket.send(event.data); }; - + socket.onclose = function() { runCase(n + 1); }; } }; - + runCase(1); }; diff --git a/examples/server.js b/examples/server.js index 5d08277..cb54715 100644 --- a/examples/server.js +++ b/examples/server.js @@ -9,11 +9,11 @@ var port = process.argv[2] || 7000, var upgradeHandler = function(request, socket, head) { var ws = new WebSocket(request, socket, head, ['irc', 'xmpp'], {ping: 5}); console.log('open', ws.url, ws.version, ws.protocol); - + ws.onmessage = function(event) { ws.send(event.data); }; - + ws.onclose = function(event) { console.log('close', event.code, event.reason); ws = null; @@ -23,12 +23,12 @@ var upgradeHandler = function(request, socket, head) { var requestHandler = function(request, response) { if (!WebSocket.EventSource.isEventSource(request)) return staticHandler(request, response); - + var es = new WebSocket.EventSource(request, response), time = parseInt(es.lastEventId, 10) || 0; - + console.log('open', es.url, es.lastEventId); - + var loop = setInterval(function() { time += 1; es.send('Time: ' + time); @@ -36,9 +36,9 @@ var requestHandler = function(request, response) { if (es) es.send('Update!!', {event: 'update', id: time}); }, 1000); }, 2000); - + es.send('Welcome!\n\nThis is an EventSource server.'); - + es.onclose = function() { clearInterval(loop); console.log('close', es.url); @@ -48,7 +48,7 @@ var requestHandler = function(request, response) { var staticHandler = function(request, response) { var path = request.url; - + fs.readFile(__dirname + path, function(err, content) { var status = err ? 404 : 200; response.writeHead(status, {'Content-Type': 'text/html'}); diff --git a/examples/sse.html b/examples/sse.html index 7d40760..2afa273 100644 --- a/examples/sse.html +++ b/examples/sse.html @@ -5,35 +5,35 @@