fl-observable-socket

fantasy-land observable-socket

Like observable-socket with more algebra. Works with ws and window.WebSocket.

Install:

npm i fl-observable-socket -S

Use:

var ws = require('ws')
var flos = require('fl-observable-socket')
 
// Wrap a WebSocket
var socket = flos(ws('wss://echo.websocket.org'))
 
// Send messages up the socket
socket.up('hello')
    .fork(e => console.error(e), a => console.log(a))
 
// Receive messages down the socket
socket.down
    .observe(msg => console.log(msg))
    .then(() => console.log('done'))
    .catch(err => console.error(err))

<script type="text/javascript" src="https://unpkg.com/fluture@4.3.0"></script>
<script type="text/javascript" src="https://unpkg.com/most@1.1.1/dist/most"></script>
<script type="text/javascript" src="https://unpkg.com/@most/create@2.0.1"></script>
<script type="text/javascript" src="https://unpkg.com/fl-observable-socket@1.0.0-rc2/dist/index.js"></script>
 
<script>
    var socket = FLObservableSocket(new WebSocket('wss://echo.websocket.org'))
 
    // Send messages up the socket
    socket.up('hello')
        .fork(e => console.error(e), a => console.log(a))
 
    // Receive messages down the socket
    socket.down
        .observe(msg => console.log(msg))
        .then(() => console.log('done'))
        .catch(err => console.error(err))
</script> 
 

API:

up: A Future down: A Stream