diff options
author | Oisin Canty <o.canty@f5.com> | 2021-05-24 09:01:42 +0000 |
---|---|---|
committer | Oisin Canty <o.canty@f5.com> | 2021-05-24 09:01:42 +0000 |
commit | c160ea11e4ece4db52731ac8b83dd09ca2d1ef11 (patch) | |
tree | ebfd605f6e93a05b65bae5c327b47a1a764a8d63 /test/node/loader/es_modules_websocket_indirect/module.mjs | |
parent | d6439002371d0bc73183c9d3d28df4f62ce0b972 (diff) | |
download | unit-c160ea11e4ece4db52731ac8b83dd09ca2d1ef11.tar.gz unit-c160ea11e4ece4db52731ac8b83dd09ca2d1ef11.tar.bz2 |
Node.js: renamed "require_shim" to "loader".
Diffstat (limited to 'test/node/loader/es_modules_websocket_indirect/module.mjs')
-rw-r--r-- | test/node/loader/es_modules_websocket_indirect/module.mjs | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/test/node/loader/es_modules_websocket_indirect/module.mjs b/test/node/loader/es_modules_websocket_indirect/module.mjs new file mode 100644 index 00000000..a71ffa9d --- /dev/null +++ b/test/node/loader/es_modules_websocket_indirect/module.mjs @@ -0,0 +1,30 @@ +import http from "http" +import websocket from "websocket" + +let server = http.createServer(function() {}); +let webSocketServer = websocket.server; + +server.listen(7080, function() {}); + +var wsServer = new webSocketServer({ + maxReceivedMessageSize: 0x1000000000, + maxReceivedFrameSize: 0x1000000000, + fragmentOutgoingMessages: false, + fragmentationThreshold: 0x1000000000, + httpServer: server, +}); + +wsServer.on('request', function(request) { + var connection = request.accept(null); + + connection.on('message', function(message) { + if (message.type === 'utf8') { + connection.send(message.utf8Data); + } else if (message.type === 'binary') { + connection.send(message.binaryData); + } + + }); + + connection.on('close', function(r) {}); +}); |