Client for @pxtrn/wss
pub/sub websocket server
npm install --save @pxtrn/ws
const Ws = require('@pxtrn/ws');
const client = new Ws('wss://example.com');
client.on('update', (update) => {
console.log(`Got update for channel ${update.channel}`, update.data);
});
client.subscribe('cats');
This class represents a websocket server with simple pub/sub. It extends EventEmitter.
url
{String} Url of the @pxtrn/wss server
-
options
{Object} Optional optionspingInterval
{Integer} Interval in ms for heartbeat ping. Default:10000
,pongTimeout
{Integer} Timeout in ms waiting for heartbeat pong response from server. Default:1000
,reconnectTimeout
{Integer} Timeout in ms the client waits before trying to reconnect after a lost connection. Default:500
-
logger
{Object}custom logger containing the following methods
const logger = { silly: function(message, data) {}, debug: function(message, data) {}, notice: function(message, data) {}, info: function(message, data) {}, warning: function(message, data) {}, error: function(message, data) {}, }
Emitted when the connection has been closed.
error
{Error}
Emitted when an error occurs.
Emitted when the has been opened.
update
{Object}channel
{String} The channel for which the update is.data
{Mixed} Data the server sent
Emitted when the server emits a channel update.
channels
{String|Array} Single channel or array of channels
Subscribe to one or more channel(s?).
channels
{String|Array} Single channel or array of channels
Unsubscribe from one or more channel(s?).
Close the connection to the server