mqtt-websocket-stream

This node module implements MQTT.js compatible duplex stream over WebSocket. It is an alternative implementation to websocket-stream that is better suited to work with MQTT.js. This module is used on aws-mqtt to connect to AWS IoT MQTT broker.

Features

• The stream implements _writev to efficiently write multiple small buffers that MQTT.js writes to the stream (MQTT.js calls cork, multiple write and then uncork on the stream to send one packet)
• Can work with browser's WebSocket, as well as server WebSocket implementation (ws)
• Supports async socket creation, when instantiation of the WebStream needs to be delayed/async, for example to async sign the url to connect to.

Usage

npm install mqtt-websocket-stream --save

In node environment:

1import MqttWebSocketStream from 'mqtt-websocket-stream'
2import WebSocket from 'ws'
3const stream = new MqttWebSocketStream(new WebSocket(url))
4stream.pipe(...).pipe(stream)

In browser environment (using Babel/Webpack):

1import MqttWebSocketStream from 'mqtt-websocket-stream'
2const stream = new MqttWebSocketStream(new window.WebSocket(url))
3stream.pipe(...).pipe(stream)

Passing an async factory:

1import MqttWebSocketStream from 'mqtt-websocket-stream'
2const stream = new MqttWebSocketStream((callback) => {
3  getSignedUrl().then(url => callback(null, new window.WebSocket(url))).catch(callback)
4})
5stream.pipe(...).pipe(stream)