2013-09-30 07:44:31 +00:00
|
|
|
Elm.Native.WebSocket = {};
|
|
|
|
Elm.Native.WebSocket.make = function(elm) {
|
2013-02-20 22:36:16 +00:00
|
|
|
|
2013-03-09 07:12:40 +00:00
|
|
|
elm.Native = elm.Native || {};
|
2013-09-30 08:32:27 +00:00
|
|
|
elm.Native.WebSocket = elm.Native.WebSocket || {};
|
|
|
|
if (elm.Native.WebSocket.values) return elm.Native.WebSocket.values;
|
2013-02-20 22:36:16 +00:00
|
|
|
|
2013-09-30 07:44:31 +00:00
|
|
|
var Signal = Elm.Signal.make(elm);
|
|
|
|
var JS = Elm.JavaScript.make(elm);
|
|
|
|
var List = Elm.Native.List.make(elm);
|
2013-03-09 07:12:40 +00:00
|
|
|
|
|
|
|
function open(url, outgoing) {
|
|
|
|
var incoming = Signal.constant(List.Nil);
|
|
|
|
var ws = new WebSocket(JS.fromString(url));
|
2013-02-20 22:36:16 +00:00
|
|
|
|
|
|
|
var pending = [];
|
|
|
|
var ready = false;
|
|
|
|
|
|
|
|
ws.onopen = function(e) {
|
|
|
|
var len = pending.length;
|
|
|
|
for (var i = 0; i < len; ++i) { ws.send(pending[i]); }
|
|
|
|
ready = true;
|
|
|
|
};
|
|
|
|
ws.onmessage = function(event) {
|
2013-03-09 07:12:40 +00:00
|
|
|
elm.notify(incoming.id, JS.toString(event.data));
|
2013-02-20 22:36:16 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
function send(msg) {
|
2013-03-09 07:12:40 +00:00
|
|
|
var s = JS.fromString(msg);
|
2013-02-20 22:36:16 +00:00
|
|
|
ready ? ws.send(s) : pending.push(s);
|
|
|
|
}
|
|
|
|
|
2013-03-09 07:12:40 +00:00
|
|
|
function take1(x,y) { return x }
|
|
|
|
return A3(Signal.lift2, F2(take1), incoming, A2(Signal.lift, send, outgoing));
|
2013-02-20 22:36:16 +00:00
|
|
|
}
|
|
|
|
|
2013-09-30 08:32:27 +00:00
|
|
|
return elm.Native.WebSocket.values = { connect: F2(open) };
|
2013-03-09 07:12:40 +00:00
|
|
|
};
|