Promise is available. If you're targeting an environment that does not
support native Promises, use
babel-polyfill or something
npm i observable-socket
import and use it.
const ObservableSocket =const WS =/*** Create an echo socket by connecting to the echo socket provided by* websocket.org.*/const echoSocket = ObservableSocket/*** Subscribing to `echoSocket` receives messages from the underlying* WebSocket.*/echoSocketdown/*** We can send messages too!*/echoSocket
This module exports a function that takes a WebSocket, and returns an object
with two properties,
up is a function to push messages up the socket. This will create
a queue of messages that will not be sent until the socket is connected.
down is an RxJS stream. You can
subscribe to it.
observable-socket does not construct WebSockets, therefore there isn't
a notion of "healing" a connection. Instead, when a socket drops, the
observable-socket is called, which can be leveraged into
creating a new socket, and re-wrapping
observable-socket around it. An
example of how this can be done:
Bundles and packages and boxes and goodies...
There are a few different bundles in